aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/MachineStudio/Tango.MachineStudio.UI/Threading/DefaultDispatcherProvider.cs
blob: 611dca6b9dca695b57d320bff246c333a999b30e (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Threading;
using Tango.MachineStudio.Common.Threading;

namespace Tango.MachineStudio.UI.Threading
{
    /// <summary>
    /// Represents the default PPC <see cref="IDispatcherProvider"/> which will invoke action on the current application dispatcher.
    /// </summary>
    /// <seealso cref="Tango.PPC.Common.Threading.IDispatcherProvider" />
    public class DefaultDispatcherProvider : IDispatcherProvider
    {
        private Dispatcher _dispatcher;

        /// <summary>
        /// Initializes a new instance of the <see cref="DefaultDispatcherProvider"/> class.
        /// </summary>
        /// <param name="dispatcher">The dispatcher.</param>
        public DefaultDispatcherProvider(Dispatcher dispatcher)
        {
            _dispatcher = dispatcher;
        }

        /// <summary>
        /// Invokes the specified action asynchronously.
        /// </summary>
        /// <param name="action">The action.</param>
        public void Invoke(Action action)
        {
            _dispatcher.BeginInvoke(action);
        }

        /// <summary>
        /// Invokes the specified action synchronously.
        /// </summary>
        /// <param name="action">The action.</param>
        public void InvokeSync(Action action)
        {
            _dispatcher.Invoke(action);
        }
    }
}
generated by cgit v1.3.1 (git 2.54.0) at 2026-07-15 08:45:54 +0000
ChangeTrackingCheckpoint { // Object that is unique per document. // Used to determine if two checkpoints belong to the same document. // We don't use a reference to the document itself to allow the GC to reclaim the document memory // even if there are still references to checkpoints. readonly object documentIdentifier; // 'value' is the change from the previous checkpoint to this checkpoint // TODO: store the change in the older checkpoint instead - if only a reference to the // newest document version exists, the GC should be able to collect all DocumentChangeEventArgs. readonly DocumentChangeEventArgs value; readonly int id; ChangeTrackingCheckpoint next; internal ChangeTrackingCheckpoint(object documentIdentifier) { this.documentIdentifier = documentIdentifier; } internal ChangeTrackingCheckpoint(object documentIdentifier, DocumentChangeEventArgs value, int id) { this.documentIdentifier = documentIdentifier; this.value = value; this.id = id; } internal ChangeTrackingCheckpoint Append(DocumentChangeEventArgs change) { Debug.Assert(this.next == null); this.next = new ChangeTrackingCheckpoint(this.documentIdentifier, change, unchecked( this.id + 1 )); return this.next; } /// <summary> /// Creates a change tracking checkpoint for the specified document. /// This method is thread-safe. /// If you need a ChangeTrackingCheckpoint that's consistent with a snapshot of the document, /// use <see cref="TextDocument.CreateSnapshot(out ChangeTrackingCheckpoint)"/>. /// </summary> public static ChangeTrackingCheckpoint Create(TextDocument document) { if (document == null) throw new ArgumentNullException("document"); return document.CreateChangeTrackingCheckpoint(); } /// <summary> /// Gets whether this checkpoint belongs to the same document as the other checkpoint. /// </summary> public bool BelongsToSameDocumentAs(ChangeTrackingCheckpoint other) { if (other == null) throw new ArgumentNullException("other"); return documentIdentifier == other.documentIdentifier; } /// <summary> /// Compares the age of this checkpoint to the other checkpoint. /// </summary> /// <remarks>This method is thread-safe.</remarks> /// <exception cref="ArgumentException">Raised if 'other' belongs to a different document than this checkpoint.</exception> /// <returns>-1 if this checkpoint is older than <paramref name="other"/>. /// 0 if <c>this</c>==<paramref name="other"/>. /// 1 if this checkpoint is newer than <paramref name="other"/>.</returns> public int CompareAge(ChangeTrackingCheckpoint other) { if (other == null) throw new ArgumentNullException("other"); if (other.documentIdentifier != this.documentIdentifier) throw new ArgumentException("Checkpoints do not belong to the same document."); // We will allow overflows, but assume that the maximum distance between checkpoints is 2^31-1. // This is guaranteed on x86 because so many checkpoints don't fit into memory. return Math.Sign(unchecked( this.id - other.id )); } /// <summary> /// Gets the changes from this checkpoint to the other checkpoint. /// If 'other' is older than this checkpoint, reverse changes are calculated. /// </summary> /// <remarks>This method is thread-safe.</remarks> /// <exception cref="ArgumentException">Raised if 'other' belongs to a different document than this checkpoint.</exception> public IEnumerable<DocumentChangeEventArgs> GetChangesTo(ChangeTrackingCheckpoint other) { int result = CompareAge(other); if (result < 0) return GetForwardChanges(other); else if (result > 0) return other.GetForwardChanges(this).Reverse().Select(change => change.Invert()); else return Empty<DocumentChangeEventArgs>.Array; } IEnumerable<DocumentChangeEventArgs> GetForwardChanges(ChangeTrackingCheckpoint other) { // Return changes from this(exclusive) to other(inclusive). ChangeTrackingCheckpoint node = this; do { node = node.next; yield return node.value; } while (node != other); } /// <summary> /// Calculates where the offset has moved in the other buffer version. /// </summary> /// <remarks>This method is thread-safe.</remarks> /// <exception cref="ArgumentException">Raised if 'other' belongs to a different document than this checkpoint.</exception> public int MoveOffsetTo(ChangeTrackingCheckpoint other, int oldOffset, AnchorMovementType movement) { int offset = oldOffset; foreach (DocumentChangeEventArgs e in GetChangesTo(other)) { offset = e.GetNewOffset(offset, movement); } return offset; } } }
generated by cgit v1.3.1 (git 2.54.0) at 2026-07-15 08:45:54 +0000