Mercurial > hg > ucis.core
view Util/AsyncResultBase.cs @ 104:327be9216006
Improved PML code
author | Ivo Smits <Ivo@UCIS.nl> |
---|---|
date | Sat, 11 Oct 2014 14:05:41 +0200 |
parents | a6faa87767bb |
children |
line wrap: on
line source
???using System; using System.Threading; using SysThreadPool = System.Threading.ThreadPool; namespace UCIS.Util { public abstract class AsyncResultBase : IAsyncResult { [ThreadStatic] static Boolean ThreadInCallback = false; ManualResetEvent WaitEvent = null; AsyncCallback Callback = null; Object MonitorWaitHandle = new Object(); public object AsyncState { get; private set; } public bool CompletedSynchronously { get; private set; } public bool IsCompleted { get; private set; } public Exception Error { get; private set; } public WaitHandle AsyncWaitHandle { get { lock (this) { if (WaitEvent == null) WaitEvent = new ManualResetEvent(IsCompleted); return WaitEvent; } } } public AsyncResultBase(AsyncCallback callback, Object state) { this.Callback = callback; this.AsyncState = state; } private void CallCallback(Object state) { if (Callback != null) Callback(this); } protected void SetCompleted(Boolean synchronously, Exception error) { this.CompletedSynchronously = synchronously; this.Error = error; lock (this) { IsCompleted = true; if (WaitEvent != null) WaitEvent.Set(); if (MonitorWaitHandle != null) lock (MonitorWaitHandle) Monitor.Pulse(MonitorWaitHandle); } if (Callback != null) { if (synchronously && !ThreadInCallback) { try { ThreadInCallback = true; Callback(this); } finally { ThreadInCallback = false; } } else { SysThreadPool.QueueUserWorkItem(CallCallback); } } } public void WaitForCompletion() { lock (this) if (!IsCompleted) lock (MonitorWaitHandle) Monitor.Wait(MonitorWaitHandle); } protected void ThrowError() { if (Error != null) throw Error; } } }