|
/// https://devblogs.microsoft.com/pfxteam/await-synchronizationcontext-and-console-apps/
|
||
|
|
|
||
|
|
using System;
|
||
|
|
using System.Collections.Concurrent;
|
||
|
|
using System.Collections.Generic;
|
||
|
|
using System.Threading;
|
||
|
|
using System.Threading.Tasks;
|
||
|
|
|
||
|
|
namespace CefSharp.OffScreen.Example
|
||
|
|
{
|
||
|
|
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();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|