diff options
Diffstat (limited to 'csharp/src/Ice/AsyncIOThread.cs')
| -rw-r--r-- | csharp/src/Ice/AsyncIOThread.cs | 20 |
1 files changed, 6 insertions, 14 deletions
diff --git a/csharp/src/Ice/AsyncIOThread.cs b/csharp/src/Ice/AsyncIOThread.cs index 0d9db92604f..b93e1548a94 100644 --- a/csharp/src/Ice/AsyncIOThread.cs +++ b/csharp/src/Ice/AsyncIOThread.cs @@ -21,16 +21,8 @@ namespace IceInternal _thread = new HelperThread(this); updateObserver(); - if(instance.initializationData().properties.getProperty("Ice.ThreadPriority").Length > 0) - { - ThreadPriority priority = IceInternal.Util.stringToThreadPriority( - instance.initializationData().properties.getProperty("Ice.ThreadPriority")); - _thread.Start(priority); - } - else - { - _thread.Start(ThreadPriority.Normal); - } + _thread.Start(Util.stringToThreadPriority( + instance.initializationData().properties.getProperty("Ice.ThreadPriority"))); } public void @@ -59,7 +51,7 @@ namespace IceInternal { Debug.Assert(!_destroyed); _queue.AddLast(callback); - System.Threading.Monitor.Pulse(this); + Monitor.Pulse(this); } } @@ -69,7 +61,7 @@ namespace IceInternal { Debug.Assert(!_destroyed); _destroyed = true; - System.Threading.Monitor.Pulse(this); + Monitor.Pulse(this); } } @@ -103,7 +95,7 @@ namespace IceInternal while(!_destroyed && _queue.Count == 0) { - System.Threading.Monitor.Wait(this); + Monitor.Wait(this); } LinkedList<ThreadPoolWorkItem> tmp = queue; @@ -140,7 +132,7 @@ namespace IceInternal if(_observer != null) { - _observer.detach(); + _observer.detach(); } } |