Update SmartThreadPool to latest version 2.2.3 with a major and minor change.

SmartThreadPool code comes from http://www.codeproject.com/Articles/7933/Smart-Thread-Pool
This version implements thread abort (via WorkItem.Cancel(true)), threadpool naming, max thread stack, etc. so we no longer need to manually patch those.
However, two changes have been made to stock 2.2.3.
Major change: WorkItem.Cancel(bool abortExecution) in our version does not succeed if the work item was in progress and thread abort was not specified.
This is to match previous behaviour where we handle co-operative termination via another mechanism rather than checking WorkItem.IsCanceled.
Minor change: Did not add STP's StopWatch implementation as this is only used WinCE and Silverlight and causes a build clash with System.Diagnostics.StopWatch
The reason for updating is to see if this improves http://opensimulator.org/mantis/view.php?id=6557 and http://opensimulator.org/mantis/view.php?id=6586

1 files changed, 104 insertions, 0 deletions

diff --git a/ThirdParty/SmartThreadPool/EventWaitHandle.cs b/ThirdParty/SmartThreadPool/EventWaitHandle.cs
new file mode 100644
index 0000000..70a1a29
--- /dev/null
+++ b/ThirdParty/SmartThreadPool/EventWaitHandle.cs
@@ -0,0 +1,104 @@
+#if (_WINDOWS_CE)

+

+using System;

+using System.Runtime.InteropServices;

+using System.Threading;

+

+namespace Amib.Threading.Internal

+{

+    /// <summary>

+    /// EventWaitHandle class

+    /// In WindowsCE this class doesn't exist and I needed the WaitAll and WaitAny implementation.

+    /// So I wrote this class to implement these two methods with some of their overloads.

+    /// It uses the WaitForMultipleObjects API to do the WaitAll and WaitAny.

+    /// Note that this class doesn't even inherit from WaitHandle!

+    /// </summary>

+    public class STPEventWaitHandle

+    {

+        #region Public Constants

+

+        public const int WaitTimeout = Timeout.Infinite;

+

+        #endregion

+

+        #region Private External Constants

+

+        private const Int32 WAIT_FAILED = -1;

+        private const Int32 WAIT_TIMEOUT = 0x102;

+        private const UInt32 INFINITE = 0xFFFFFFFF;

+

+        #endregion

+

+        #region WaitAll and WaitAny

+

+        internal static bool WaitOne(WaitHandle waitHandle, int millisecondsTimeout, bool exitContext)

+        {

+            return waitHandle.WaitOne(millisecondsTimeout, exitContext);

+        }

+

+            private static IntPtr[] PrepareNativeHandles(WaitHandle[] waitHandles)

+            {

+                IntPtr[] nativeHandles = new IntPtr[waitHandles.Length];

+                for (int i = 0; i < waitHandles.Length; i++)

+                {

+                nativeHandles[i] = waitHandles[i].Handle;

+                }

+                return nativeHandles;

+            }

+

+            public static bool WaitAll(WaitHandle[] waitHandles, int millisecondsTimeout, bool exitContext)

+            {

+            uint timeout = millisecondsTimeout < 0 ? INFINITE : (uint)millisecondsTimeout;

+

+            IntPtr[] nativeHandles = PrepareNativeHandles(waitHandles);

+

+                int result = WaitForMultipleObjects((uint)waitHandles.Length, nativeHandles, true, timeout);

+

+            if (result == WAIT_TIMEOUT || result == WAIT_FAILED)

+            {

+                return false;

+            }

+

+                return true;

+            }

+

+

+            public static int WaitAny(WaitHandle[] waitHandles, int millisecondsTimeout, bool exitContext)

+        {

+            uint timeout = millisecondsTimeout < 0 ? INFINITE : (uint)millisecondsTimeout;

+

+            IntPtr[] nativeHandles = PrepareNativeHandles(waitHandles);

+

+            int result = WaitForMultipleObjects((uint)waitHandles.Length, nativeHandles, false, timeout);

+

+            if (result >= 0 && result < waitHandles.Length)

+            {

+                return result;

+            }

+

+            return -1;

+        }

+

+        public static int WaitAny(WaitHandle[] waitHandles)

+        {

+            return WaitAny(waitHandles, Timeout.Infinite, false);

+        }

+

+        public static int WaitAny(WaitHandle[] waitHandles, TimeSpan timeout, bool exitContext)

+        {

+            int millisecondsTimeout = (int)timeout.TotalMilliseconds;

+

+            return WaitAny(waitHandles, millisecondsTimeout, false);

+        }

+ 

+        #endregion

+

+        #region External methods

+

+        [DllImport("coredll.dll", SetLastError = true)]

+        public static extern int WaitForMultipleObjects(uint nCount, IntPtr[] lpHandles, bool fWaitAll, uint dwMilliseconds);

+

+        #endregion

+    }

+}

+#endif
\ No newline at end of file