Mercurial > hg > ucis.core
annotate Util/AsyncResultBase.cs @ 7:4b78cc5f116b
Fixes and improvements (some untested)
| author | Ivo Smits <Ivo@UCIS.nl> |
|---|---|
| date | Sun, 13 Jan 2013 18:44:17 +0100 |
| parents | 2933f7750542 |
| children | a6faa87767bb |
| rev | line source |
|---|---|
| 5 | 1 ???using System; |
| 2 using System.Threading; | |
| 3 using SysThreadPool = System.Threading.ThreadPool; | |
| 4 | |
| 5 namespace UCIS.Util { | |
| 6 public abstract class AsyncResultBase : IAsyncResult { | |
| 7 ManualResetEvent WaitEvent = null; | |
| 8 AsyncCallback Callback = null; | |
| 9 public object AsyncState { get; private set; } | |
| 10 public bool CompletedSynchronously { get; private set; } | |
| 11 public bool IsCompleted { get; private set; } | |
| 12 public Exception Error { get; private set; } | |
| 13 public WaitHandle AsyncWaitHandle { | |
| 14 get { | |
| 15 lock (this) { | |
| 16 if (WaitEvent == null) WaitEvent = new ManualResetEvent(IsCompleted); | |
| 17 return WaitEvent; | |
| 18 } | |
| 19 } | |
| 20 } | |
| 21 | |
| 22 public AsyncResultBase(AsyncCallback callback, Object state) { | |
| 23 this.Callback = callback; | |
| 24 this.AsyncState = state; | |
| 25 } | |
| 26 | |
| 27 private void CallCallback(Object state) { | |
| 28 if (Callback != null) Callback(this); | |
| 29 } | |
| 30 | |
| 31 protected void SetCompleted(Boolean synchronously, Exception error) { | |
| 32 this.CompletedSynchronously = synchronously; | |
| 33 this.Error = error; | |
| 34 lock (this) { | |
| 35 IsCompleted = true; | |
| 36 if (WaitEvent != null) WaitEvent.Set(); | |
| 37 } | |
|
7
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
38 if (Callback != null) { |
|
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
39 if (synchronously) { |
|
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
40 Callback(this); |
|
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
41 } else { |
|
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
42 SysThreadPool.QueueUserWorkItem(CallCallback); |
|
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
43 } |
|
4b78cc5f116b
Fixes and improvements (some untested)
Ivo Smits <Ivo@UCIS.nl>
parents:
5
diff
changeset
|
44 } |
| 5 | 45 } |
| 46 | |
| 47 protected void ThrowError() { | |
| 48 if (Error != null) throw Error; | |
| 49 } | |
| 50 } | |
| 51 } |