CefSharp.MinimalExample/CefSharp.MinimalExample.Off.../SingleThreadSynchronization...

33 lines
969 B
C#

/// https://devblogs.microsoft.com/pfxteam/await-synchronizationcontext-and-console-apps/
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Threading;
namespace CefSharp.MinimalExample.OffScreen
{
public sealed class SingleThreadSynchronizationContext : SynchronizationContext
{
private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> queue =
new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();
public override void Post(SendOrPostCallback d, object state)
{
queue.Add(new KeyValuePair<SendOrPostCallback, object>(d, state));
}
public void RunOnCurrentThread()
{
while (queue.TryTake(out var workItem, Timeout.Infinite))
{
workItem.Key(workItem.Value);
}
}
public void Complete()
{
queue.CompleteAdding();
}
}
}