ExecutorSynchronizationContext.cs

Go to the documentation of this file.

using System;
using System.Threading;
using System.Threading.Tasks;
 
#if FIRST_PASS == false
 
using java.lang;
using java.util.concurrent;
 
namespace IKVM.Runtime.Util.Java.Util.Concurrent
{
 
    class ExecutorSynchronizationContext : SynchronizationContext
    {
 
        class TaskRunnable : Runnable
        {
 
            readonly ExecutorSynchronizationContext self;
            readonly SendOrPostCallback post;
            readonly object state;
 
            public TaskRunnable(ExecutorSynchronizationContext self, SendOrPostCallback post, object state)
            {
                this.self = self ?? throw new ArgumentNullException(nameof(self));
                this.post = post ?? throw new ArgumentNullException(nameof(post));
                this.state = state;
            }
 
            public void run()
            {
                var save = Current;
 
                try
                {
                    SetSynchronizationContext(self);
                    post(state);
                }
                finally
                {
                    SetSynchronizationContext(save);
                }
            }
 
        }
 
        readonly Executor executor;
 
        public ExecutorSynchronizationContext(Executor executor)
        {
            this.executor = executor ?? throw new ArgumentNullException(nameof(executor));
        }
 
        public override void Post(SendOrPostCallback d, object state)
        {
            executor.execute(new TaskRunnable(this, d, state));
        }
 
    }
 
}
 
#endif