123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104 |
- #if (_WINDOWS_CE)
- using System;
- using System.Runtime.InteropServices;
- using System.Threading;
- namespace Amib.Threading.Internal
- {
-
-
-
-
-
-
-
- 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
|