mirror of
https://github.com/opensim/opensim.git
synced 2026-05-15 19:35:41 +08:00
206fb306a7
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
83 lines
2.8 KiB
C#
83 lines
2.8 KiB
C#
using System.Threading;
|
|
|
|
#if (_WINDOWS_CE)
|
|
using System;
|
|
using System.Runtime.InteropServices;
|
|
#endif
|
|
|
|
namespace Amib.Threading.Internal
|
|
{
|
|
/// <summary>
|
|
/// EventWaitHandleFactory class.
|
|
/// This is a static class that creates AutoResetEvent and ManualResetEvent objects.
|
|
/// In WindowCE the WaitForMultipleObjects API fails to use the Handle property
|
|
/// of XxxResetEvent. It can use only handles that were created by the CreateEvent API.
|
|
/// Consequently this class creates the needed XxxResetEvent and replaces the handle if
|
|
/// it's a WindowsCE OS.
|
|
/// </summary>
|
|
public static class EventWaitHandleFactory
|
|
{
|
|
/// <summary>
|
|
/// Create a new AutoResetEvent object
|
|
/// </summary>
|
|
/// <returns>Return a new AutoResetEvent object</returns>
|
|
public static AutoResetEvent CreateAutoResetEvent()
|
|
{
|
|
AutoResetEvent waitHandle = new AutoResetEvent(false);
|
|
|
|
#if (_WINDOWS_CE)
|
|
ReplaceEventHandle(waitHandle, false, false);
|
|
#endif
|
|
|
|
return waitHandle;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Create a new ManualResetEvent object
|
|
/// </summary>
|
|
/// <returns>Return a new ManualResetEvent object</returns>
|
|
public static ManualResetEvent CreateManualResetEvent(bool initialState)
|
|
{
|
|
ManualResetEvent waitHandle = new ManualResetEvent(initialState);
|
|
|
|
#if (_WINDOWS_CE)
|
|
ReplaceEventHandle(waitHandle, true, initialState);
|
|
#endif
|
|
|
|
return waitHandle;
|
|
}
|
|
|
|
#if (_WINDOWS_CE)
|
|
|
|
/// <summary>
|
|
/// Replace the event handle
|
|
/// </summary>
|
|
/// <param name="waitHandle">The WaitHandle object which its handle needs to be replaced.</param>
|
|
/// <param name="manualReset">Indicates if the event is a ManualResetEvent (true) or an AutoResetEvent (false)</param>
|
|
/// <param name="initialState">The initial state of the event</param>
|
|
private static void ReplaceEventHandle(WaitHandle waitHandle, bool manualReset, bool initialState)
|
|
{
|
|
// Store the old handle
|
|
IntPtr oldHandle = waitHandle.Handle;
|
|
|
|
// Create a new event
|
|
IntPtr newHandle = CreateEvent(IntPtr.Zero, manualReset, initialState, null);
|
|
|
|
// Replace the old event with the new event
|
|
waitHandle.Handle = newHandle;
|
|
|
|
// Close the old event
|
|
CloseHandle (oldHandle);
|
|
}
|
|
|
|
[DllImport("coredll.dll", SetLastError = true)]
|
|
public static extern IntPtr CreateEvent(IntPtr lpEventAttributes, bool bManualReset, bool bInitialState, string lpName);
|
|
|
|
//Handle
|
|
[DllImport("coredll.dll", SetLastError = true)]
|
|
public static extern bool CloseHandle(IntPtr hObject);
|
|
#endif
|
|
|
|
}
|
|
}
|