Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Update to Avalonia@a08f4ac9 (Mar 31 2023) (#29)
- Loading branch information
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,132 @@ | ||
| #nullable enable | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Diagnostics; | ||
| using System.Runtime.ExceptionServices; | ||
| using System.Threading; | ||
| using Modern.WindowKit.Mac.Interop; | ||
| using Modern.WindowKit.Threading; | ||
| using Modern.WindowKit.MicroCom; | ||
|
|
||
| namespace Modern.WindowKit.Native; | ||
|
|
||
| internal class DispatcherImpl : IControlledDispatcherImpl, IDispatcherImplWithExplicitBackgroundProcessing | ||
| { | ||
| private readonly IAvnPlatformThreadingInterface _native; | ||
| private Thread? _loopThread; | ||
| private Stopwatch _clock = Stopwatch.StartNew(); | ||
| private Stack<RunLoopFrame> _managedFrames = new(); | ||
|
|
||
| public DispatcherImpl(IAvnPlatformThreadingInterface native) | ||
| { | ||
| _native = native; | ||
| using var events = new Events(this); | ||
| _native.SetEvents(events); | ||
| } | ||
|
|
||
| public event Action Signaled; | ||
| public event Action Timer; | ||
| public event Action ReadyForBackgroundProcessing; | ||
|
|
||
| private class Events : NativeCallbackBase, IAvnPlatformThreadingInterfaceEvents | ||
| { | ||
| private readonly DispatcherImpl _parent; | ||
|
|
||
| public Events(DispatcherImpl parent) | ||
| { | ||
| _parent = parent; | ||
| } | ||
| public void Signaled() => _parent.Signaled?.Invoke(); | ||
|
|
||
| public void Timer() => _parent.Timer?.Invoke(); | ||
|
|
||
| public void ReadyForBackgroundProcessing() => _parent.ReadyForBackgroundProcessing?.Invoke(); | ||
| } | ||
|
|
||
| public bool CurrentThreadIsLoopThread | ||
| { | ||
| get | ||
| { | ||
| if (_loopThread != null) | ||
| return Thread.CurrentThread == _loopThread; | ||
| if (_native.CurrentThreadIsLoopThread == 0) | ||
| return false; | ||
| _loopThread = Thread.CurrentThread; | ||
| return true; | ||
| } | ||
| } | ||
|
|
||
| public void Signal() => _native.Signal(); | ||
|
|
||
| public void UpdateTimer(long? dueTimeInMs) | ||
| { | ||
| var ms = dueTimeInMs == null ? -1 : (int)Math.Min(int.MaxValue - 10, Math.Max(1, dueTimeInMs.Value - Now)); | ||
| _native.UpdateTimer(ms); | ||
| } | ||
|
|
||
| public bool CanQueryPendingInput => false; | ||
| public bool HasPendingInput => false; | ||
|
|
||
| class RunLoopFrame : IDisposable | ||
| { | ||
| public ExceptionDispatchInfo? Exception; | ||
| public CancellationTokenSource CancellationTokenSource = new(); | ||
|
|
||
| public RunLoopFrame(CancellationToken token) | ||
| { | ||
| CancellationTokenSource = CancellationTokenSource.CreateLinkedTokenSource(token); | ||
| } | ||
|
|
||
| public void Dispose() => CancellationTokenSource.Dispose(); | ||
| } | ||
|
|
||
| public void RunLoop(CancellationToken token) | ||
| { | ||
| if (token.IsCancellationRequested) | ||
| return; | ||
| object l = new(); | ||
| var exited = false; | ||
|
|
||
| using var frame = new RunLoopFrame(token); | ||
|
|
||
| using var cancel = _native.CreateLoopCancellation(); | ||
| frame.CancellationTokenSource.Token.Register(() => | ||
| { | ||
| lock (l) | ||
| // ReSharper disable once AccessToModifiedClosure | ||
| // ReSharper disable once AccessToDisposedClosure | ||
| if (!exited) | ||
| cancel.Cancel(); | ||
| }); | ||
|
|
||
| try | ||
| { | ||
| _managedFrames.Push(frame); | ||
| _native.RunLoop(cancel); | ||
| } | ||
| finally | ||
| { | ||
| lock (l) | ||
| exited = true; | ||
| _managedFrames.Pop(); | ||
| if (frame.Exception != null) | ||
| frame.Exception.Throw(); | ||
| } | ||
| } | ||
|
|
||
| public long Now => _clock.ElapsedMilliseconds; | ||
|
|
||
| public void PropagateCallbackException(ExceptionDispatchInfo capture) | ||
| { | ||
| if (_managedFrames.Count == 0) | ||
| { | ||
| Debug.Assert(false, "We should never get here"); | ||
| return; | ||
| } | ||
|
|
||
| var frame = _managedFrames.Peek(); | ||
| frame.Exception = capture; | ||
| frame.CancellationTokenSource.Cancel(); | ||
| } | ||
| public void RequestBackgroundProcessing() => _native.RequestBackgroundProcessing(); | ||
| } |
Oops, something went wrong.