-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
13 changed files
with
710 additions
and
89 deletions.
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,41 +1,44 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk"> | ||
|
|
||
| <PropertyGroup> | ||
| <UseWPF>true</UseWPF> | ||
| <IsPackable>false</IsPackable> | ||
| <GenerateAssemblyInfo>false</GenerateAssemblyInfo> | ||
| <Configurations>Debug;Release</Configurations> | ||
| <Platforms>AnyCPU</Platforms> | ||
| <LangVersion>10</LangVersion> | ||
| <AllowUnsafeBlocks>true</AllowUnsafeBlocks> | ||
| <GenerateAssemblyInfo>false</GenerateAssemblyInfo> | ||
| <TargetFramework>net6-windows10.0.20348.0</TargetFramework> | ||
| <NoWarn>CA1416;NU1701;CS0649;CS0414;CS1998</NoWarn> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <SupportedPlatform Include="windows" /> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <PackageReference Include="DeltaCompressionDotNet" Version="2.0.0"><NoWarn>NU1701</NoWarn></PackageReference> | ||
| <PackageReference Include="JetBrains.Annotations" Version="2019.1.3" /> | ||
| <PackageReference Include="log4net" Version="2.0.8" /> | ||
| <PackageReference Include="Microsoft.Data.OData" Version="5.6.1" /> | ||
| <PackageReference Include="Mono.Cecil" Version="0.11.3" /> | ||
| <PackageReference Include="Prism.Core" Version="7.2.0.1367" /> | ||
| <PackageReference Include="Prism.Unity" Version="7.2.0.1367" /> | ||
| <PackageReference Include="Prism.Wpf" Version="7.2.0.1367" /> | ||
| <PackageReference Include="PropertyChanged.Fody" Version="3.4.0" PrivateAssets="All"><ExcludeAssets>runtime</ExcludeAssets><IncludeAssets>All</IncludeAssets></PackageReference> | ||
| <PackageReference Include="SpicyTaco.AutoGrid" Version="1.2.29"><NoWarn>NU1701</NoWarn></PackageReference> | ||
| <PackageReference Include="squirrel.windows" Version="1.9.0"><NoWarn>NU1701;NU1608</NoWarn></PackageReference> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <ProjectReference Include="..\PoeShared.Squirrel.Shared\PoeShared.Squirrel.Shared.csproj" /> | ||
| <ProjectReference Include="..\PoeShared\PoeShared.csproj" /> | ||
| <ProjectReference Include="..\PoeShared.Native\PoeShared.Native.csproj" /> | ||
| <ProjectReference Include="..\PoeShared.Wpf\PoeShared.Wpf.csproj" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> | ||
| <PropertyGroup> | ||
| <UseWPF>true</UseWPF> | ||
| <IsPackable>false</IsPackable> | ||
| <GenerateAssemblyInfo>false</GenerateAssemblyInfo> | ||
| <Configurations>Debug;Release</Configurations> | ||
| <Platforms>AnyCPU</Platforms> | ||
| <LangVersion>10</LangVersion> | ||
| <AllowUnsafeBlocks>true</AllowUnsafeBlocks> | ||
| <GenerateAssemblyInfo>false</GenerateAssemblyInfo> | ||
| <TargetFramework>net7-windows</TargetFramework> | ||
| <NoWarn>CA1416;NU1701;CS0649;CS0414;CS1998</NoWarn> | ||
| </PropertyGroup> | ||
| <ItemGroup> | ||
| <SupportedPlatform Include="windows" /> | ||
| </ItemGroup> | ||
| <ItemGroup> | ||
| <PackageReference Include="JetBrains.Annotations" Version="2019.1.3" /> | ||
| <PackageReference Include="log4net" Version="2.0.8" /> | ||
| <PackageReference Include="Mono.Cecil" Version="0.11.3" /> | ||
| <PackageReference Include="Prism.Unity" Version="7.2.0.1367" /> | ||
| <PackageReference Include="PropertyChanged.Fody" Version="3.4.0" PrivateAssets="All"> | ||
| <ExcludeAssets>runtime</ExcludeAssets> | ||
| <IncludeAssets>All</IncludeAssets> | ||
| </PackageReference> | ||
| <PackageReference Include="SpicyTaco.AutoGrid" Version="1.2.29"> | ||
| <NoWarn>NU1701</NoWarn> | ||
| </PackageReference> | ||
| <PackageReference Include="squirrel.windows" Version="1.9.0"> | ||
| <NoWarn>NU1701;NU1608</NoWarn> | ||
| </PackageReference> | ||
| <PackageReference Include="DeltaCompressionDotNet" Version="2.0.1" /> | ||
| <PackageReference Include="Microsoft.Data.OData" Version="5.8.5" /> | ||
| <PackageReference Include="Microsoft.DotNet.UpgradeAssistant.Extensions.Default.Analyzers" Version="0.4.410601"> | ||
| <PrivateAssets>all</PrivateAssets> | ||
| </PackageReference> | ||
| </ItemGroup> | ||
| <ItemGroup> | ||
| <ProjectReference Include="..\PoeShared.Squirrel.Shared\PoeShared.Squirrel.Shared.csproj" /> | ||
| <ProjectReference Include="..\PoeShared\PoeShared.csproj" /> | ||
| <ProjectReference Include="..\PoeShared.Native\PoeShared.Native.csproj" /> | ||
| <ProjectReference Include="..\PoeShared.Wpf\PoeShared.Wpf.csproj" /> | ||
| </ItemGroup> | ||
| </Project> |
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,208 @@ | ||
| using System; | ||
| using System.Reactive.Concurrency; | ||
| using System.Threading; | ||
| using System.Windows.Threading; | ||
| using System.Reactive.Disposables; | ||
|
|
||
| namespace PoeShared.Modularity; | ||
|
|
||
| /// <summary> | ||
| /// Represents an object that schedules units of work on a <see cref="System.Windows.Threading.Dispatcher"/>. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// This scheduler type is typically used indirectly through the <see cref="Linq.DispatcherObservable.ObserveOnDispatcher{TSource}(IObservable{TSource})"/> and <see cref="Linq.DispatcherObservable.SubscribeOnDispatcher{TSource}(IObservable{TSource})"/> methods that use the Dispatcher on the calling thread. | ||
| /// </remarks> | ||
| public sealed class DispatcherScheduler : LocalScheduler, ISchedulerPeriodic | ||
| { | ||
|
|
||
| /// <summary> | ||
| /// Gets the scheduler that schedules work on the <see cref="System.Windows.Threading.Dispatcher"/> for the current thread. | ||
| /// </summary> | ||
| public static DispatcherScheduler Current | ||
| { | ||
| get | ||
| { | ||
| var dispatcher = System.Windows.Threading.Dispatcher.FromThread(Thread.CurrentThread); | ||
| if (dispatcher == null) | ||
| { | ||
| throw new InvalidOperationException("NO_DISPATCHER_CURRENT_THREAD"); | ||
| } | ||
|
|
||
| return new DispatcherScheduler(dispatcher); | ||
| } | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Constructs a <see cref="DispatcherScheduler"/> that schedules units of work on the given <see cref="System.Windows.Threading.Dispatcher"/>. | ||
| /// </summary> | ||
| /// <param name="dispatcher"><see cref="DispatcherScheduler"/> to schedule work on.</param> | ||
| /// <exception cref="ArgumentNullException"><paramref name="dispatcher"/> is <c>null</c>.</exception> | ||
| public DispatcherScheduler(System.Windows.Threading.Dispatcher dispatcher) | ||
| { | ||
| Dispatcher = dispatcher ?? throw new ArgumentNullException(nameof(dispatcher)); | ||
| Priority = System.Windows.Threading.DispatcherPriority.Normal; | ||
|
|
||
| } | ||
|
|
||
| /// <summary> | ||
| /// Constructs a <see cref="DispatcherScheduler"/> that schedules units of work on the given <see cref="System.Windows.Threading.Dispatcher"/> at the given priority. | ||
| /// </summary> | ||
| /// <param name="dispatcher"><see cref="DispatcherScheduler"/> to schedule work on.</param> | ||
| /// <param name="priority">Priority at which units of work are scheduled.</param> | ||
| /// <exception cref="ArgumentNullException"><paramref name="dispatcher"/> is <c>null</c>.</exception> | ||
| public DispatcherScheduler(System.Windows.Threading.Dispatcher dispatcher, System.Windows.Threading.DispatcherPriority priority) | ||
| { | ||
| Dispatcher = dispatcher ?? throw new ArgumentNullException(nameof(dispatcher)); | ||
| Priority = priority; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Gets the <see cref="System.Windows.Threading.Dispatcher"/> associated with the <see cref="DispatcherScheduler"/>. | ||
| /// </summary> | ||
| public System.Windows.Threading.Dispatcher Dispatcher { get; } | ||
|
|
||
| /// <summary> | ||
| /// Gets the priority at which work items will be dispatched. | ||
| /// </summary> | ||
| public System.Windows.Threading.DispatcherPriority Priority { get; } | ||
|
|
||
| /// <summary> | ||
| /// Schedules an action to be executed on the dispatcher. | ||
| /// </summary> | ||
| /// <typeparam name="TState">The type of the state passed to the scheduled action.</typeparam> | ||
| /// <param name="state">State passed to the action to be executed.</param> | ||
| /// <param name="action">Action to be executed.</param> | ||
| /// <returns>The disposable object used to cancel the scheduled action (best effort).</returns> | ||
| /// <exception cref="ArgumentNullException"><paramref name="action"/> is <c>null</c>.</exception> | ||
| public override IDisposable Schedule<TState>(TState state, Func<IScheduler, TState, IDisposable> action) | ||
| { | ||
| if (action == null) | ||
| { | ||
| throw new ArgumentNullException(nameof(action)); | ||
| } | ||
|
|
||
| var d = new SingleAssignmentDisposable(); | ||
|
|
||
| Dispatcher.BeginInvoke( | ||
| new Action(() => | ||
| { | ||
| if (!d.IsDisposed) | ||
| { | ||
| d.Disposable = action(this, state); | ||
| } | ||
| }), | ||
| Priority | ||
| ); | ||
|
|
||
| return d; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Schedules an action to be executed after <paramref name="dueTime"/> on the dispatcher, using a <see cref="System.Windows.Threading.DispatcherTimer"/> object. | ||
| /// </summary> | ||
| /// <typeparam name="TState">The type of the state passed to the scheduled action.</typeparam> | ||
| /// <param name="state">State passed to the action to be executed.</param> | ||
| /// <param name="action">Action to be executed.</param> | ||
| /// <param name="dueTime">Relative time after which to execute the action.</param> | ||
| /// <returns>The disposable object used to cancel the scheduled action (best effort).</returns> | ||
| /// <exception cref="ArgumentNullException"><paramref name="action"/> is <c>null</c>.</exception> | ||
| public override IDisposable Schedule<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action) | ||
| { | ||
| if (action == null) | ||
| { | ||
| throw new ArgumentNullException(nameof(action)); | ||
| } | ||
|
|
||
| var dt = Scheduler.Normalize(dueTime); | ||
| if (dt.Ticks == 0) | ||
| { | ||
| return Schedule(state, action); | ||
| } | ||
|
|
||
| return ScheduleSlow(state, dt, action); | ||
| } | ||
|
|
||
| private IDisposable ScheduleSlow<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action) | ||
| { | ||
| var d = new MultipleAssignmentDisposable(); | ||
|
|
||
| var timer = new System.Windows.Threading.DispatcherTimer(Priority, Dispatcher); | ||
|
|
||
| timer.Tick += (s, e) => | ||
| { | ||
| var t = Interlocked.Exchange(ref timer, null); | ||
| if (t != null) | ||
| { | ||
| try | ||
| { | ||
| d.Disposable = action(this, state); | ||
| } | ||
| finally | ||
| { | ||
| t.Stop(); | ||
| action = static (s, t) => Disposable.Empty; | ||
| } | ||
| } | ||
| }; | ||
|
|
||
| timer.Interval = dueTime; | ||
| timer.Start(); | ||
|
|
||
| d.Disposable = Disposable.Create(() => | ||
| { | ||
| var t = Interlocked.Exchange(ref timer, null); | ||
| if (t != null) | ||
| { | ||
| t.Stop(); | ||
| action = static (s, t) => Disposable.Empty; | ||
| } | ||
| }); | ||
|
|
||
| return d; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Schedules a periodic piece of work on the dispatcher, using a <see cref="System.Windows.Threading.DispatcherTimer"/> object. | ||
| /// </summary> | ||
| /// <typeparam name="TState">The type of the state passed to the scheduled action.</typeparam> | ||
| /// <param name="state">Initial state passed to the action upon the first iteration.</param> | ||
| /// <param name="period">Period for running the work periodically.</param> | ||
| /// <param name="action">Action to be executed, potentially updating the state.</param> | ||
| /// <returns>The disposable object used to cancel the scheduled recurring action (best effort).</returns> | ||
| /// <exception cref="ArgumentNullException"><paramref name="action"/> is <c>null</c>.</exception> | ||
| /// <exception cref="ArgumentOutOfRangeException"><paramref name="period"/> is less than <see cref="TimeSpan.Zero"/>.</exception> | ||
| public IDisposable SchedulePeriodic<TState>(TState state, TimeSpan period, Func<TState, TState> action) | ||
| { | ||
| if (period < TimeSpan.Zero) | ||
| { | ||
| throw new ArgumentOutOfRangeException(nameof(period)); | ||
| } | ||
|
|
||
| if (action == null) | ||
| { | ||
| throw new ArgumentNullException(nameof(action)); | ||
| } | ||
|
|
||
| var timer = new System.Windows.Threading.DispatcherTimer(Priority, Dispatcher); | ||
|
|
||
| var state1 = state; | ||
|
|
||
| timer.Tick += (s, e) => | ||
| { | ||
| state1 = action(state1); | ||
| }; | ||
|
|
||
| timer.Interval = period; | ||
| timer.Start(); | ||
|
|
||
| return Disposable.Create(() => | ||
| { | ||
| var t = Interlocked.Exchange(ref timer, null); | ||
| if (t != null) | ||
| { | ||
| t.Stop(); | ||
| action = static _ => _; | ||
| } | ||
| }); | ||
| } | ||
| } |
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
Oops, something went wrong.