ThreadPool 类

[HostProtectionAttribute(SecurityAction.LinkDemand, Synchronization = true, 	ExternalThreading = true)]public static class ThreadPool

#region 程序集 mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089// C:\Program Files (x86)\Reference Assemblies\Microsoft\Framework\.NETFramework\v4.0\mscorlib.dll#endregionusing System.Runtime.InteropServices;using System.Security;namespace System.Threading{    //    // 摘要:    //     提供一个线程池，该线程池可用于发送工作项、处理异步 I/O、代表其他线程等待以及处理计时器。    public static class ThreadPool    {        //        // 摘要:        //     将操作系统句柄绑定到 System.Threading.ThreadPool。        //        // 参数:        //   osHandle:        //     保存操作系统句柄的 System.Runtime.InteropServices.SafeHandle。在非托管端必须为重叠 I/O 打开该句柄。        //        // 返回结果:        //     如果绑定了句柄，则为 true；否则为 false。        //        // 异常:        //   T:System.ArgumentNullException:        //     osHandle 为 null。        [SecuritySafeCritical]        public static bool BindHandle(SafeHandle osHandle);        //        // 摘要:        //     将操作系统句柄绑定到 System.Threading.ThreadPool。        //        // 参数:        //   osHandle:        //     持有句柄的 System.IntPtr。在非托管端必须为重叠 I/O 打开该句柄。        //        // 返回结果:        //     如果绑定了句柄，则为 true；否则为 false。        //        // 异常:        //   T:System.Security.SecurityException:        //     调用方没有所要求的权限。        [Obsolete("ThreadPool.BindHandle(IntPtr) has been deprecated.  Please use ThreadPool.BindHandle(SafeHandle) instead.", false)]        [SecuritySafeCritical]        public static bool BindHandle(IntPtr osHandle);        //        // 摘要:        //     检索由 System.Threading.ThreadPool.GetMaxThreads(System.Int32@,System.Int32@) 方法返回的最大线程池线程数和当前活动线程数之间的差值。        //        // 参数:        //   workerThreads:        //     可用辅助线程的数目。        //        //   completionPortThreads:        //     可用异步 I/O 线程的数目。        [SecuritySafeCritical]        public static void GetAvailableThreads(out int workerThreads, out int completionPortThreads);        //        // 摘要:        //     检索可以同时处于活动状态的线程池请求的数目。所有大于此数目的请求将保持排队状态，直到线程池线程变为可用。        //        // 参数:        //   workerThreads:        //     线程池中辅助线程的最大数目。        //        //   completionPortThreads:        //     线程池中异步 I/O 线程的最大数目。        [SecuritySafeCritical]        public static void GetMaxThreads(out int workerThreads, out int completionPortThreads);        //        // 摘要:        //     检索线程池在新请求预测中维护的空闲线程数。        //        // 参数:        //   workerThreads:        //     当前由线程池维护的空闲辅助线程的最小数目。        //        //   completionPortThreads:        //     当前由线程池维护的空闲异步 I/O 线程的最小数目。        [SecuritySafeCritical]        public static void GetMinThreads(out int workerThreads, out int completionPortThreads);        //        // 摘要:        //     将方法排入队列以便执行。此方法在有线程池线程变得可用时执行。        //        // 参数:        //   callBack:        //     一个 System.Threading.WaitCallback，表示要执行的方法。        //        // 返回结果:        //     如果此方法成功排队，则为 true；如果未能将该工作项排队，则引发 System.NotSupportedException。        //        // 异常:        //   T:System.ArgumentNullException:        //     callBack 为 null。        //        //   T:System.NotSupportedException:        //     承载公共语言运行时 (CLR) 的宿主不支持此操作。        [SecuritySafeCritical]        public static bool QueueUserWorkItem(WaitCallback callBack);        //        // 摘要:        //     将方法排入队列以便执行，并指定包含该方法所用数据的对象。此方法在有线程池线程变得可用时执行。        //        // 参数:        //   callBack:        //     System.Threading.WaitCallback，它表示要执行的方法。        //        //   state:        //     包含方法所用数据的对象。        //        // 返回结果:        //     如果此方法成功排队，则为 true；如果未能将该工作项排队，则引发 System.NotSupportedException。        //        // 异常:        //   T:System.NotSupportedException:        //     承载公共语言运行时 (CLR) 的宿主不支持此操作。        //        //   T:System.ArgumentNullException:        //     callBack 为 null。        [SecuritySafeCritical]        public static bool QueueUserWorkItem(WaitCallback callBack, object state);        //        // 摘要:        //     注册一个等待 System.Threading.WaitHandle 的委托，并指定一个 System.TimeSpan 值来表示超时时间。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的 System.Threading.WaitOrTimerCallback 委托。        //        //   state:        //     传递给委托的对象。        //        //   timeout:        //     System.TimeSpan 表示的超时时间。如果 timeout 为 0（零），则函数将测试对象的状态并立即返回。如果 timeout 为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     封装本机句柄的 System.Threading.RegisteredWaitHandle。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     timeout 参数小于 -1。        //        //   T:System.NotSupportedException:        //     timeout 参数大于 System.Int32.MaxValue。        [SecuritySafeCritical]        public static RegisteredWaitHandle RegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, TimeSpan timeout, bool executeOnlyOnce);        //        // 摘要:        //     注册一个等待 System.Threading.WaitHandle 的委托，并指定一个 64 位有符号整数来表示超时值（以毫秒为单位）。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的 System.Threading.WaitOrTimerCallback 委托。        //        //   state:        //     传递给委托的对象。        //        //   millisecondsTimeOutInterval:        //     以毫秒为单位的超时。如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。如果 millisecondsTimeOutInterval        //     为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     封装本机句柄的 System.Threading.RegisteredWaitHandle。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     millisecondsTimeOutInterval 参数小于 -1。        [SecuritySafeCritical]        public static RegisteredWaitHandle RegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, long millisecondsTimeOutInterval, bool executeOnlyOnce);        //        // 摘要:        //     注册一个等待 System.Threading.WaitHandle 的委托，并指定一个 32 位有符号整数来表示超时值（以毫秒为单位）。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的 System.Threading.WaitOrTimerCallback 委托。        //        //   state:        //     传递给委托的对象。        //        //   millisecondsTimeOutInterval:        //     以毫秒为单位的超时。如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。如果 millisecondsTimeOutInterval        //     为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     封装本机句柄的 System.Threading.RegisteredWaitHandle。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     millisecondsTimeOutInterval 参数小于 -1。        [SecuritySafeCritical]        public static RegisteredWaitHandle RegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, int millisecondsTimeOutInterval, bool executeOnlyOnce);        //        // 摘要:        //     指定表示超时（以毫秒为单位）的 32 位无符号整数，注册一个委托等待 System.Threading.WaitHandle。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的 System.Threading.WaitOrTimerCallback 委托。        //        //   state:        //     传递给委托的对象。        //        //   millisecondsTimeOutInterval:        //     以毫秒为单位的超时。如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。如果 millisecondsTimeOutInterval        //     为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     System.Threading.RegisteredWaitHandle，可用于取消已注册的等待操作。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     millisecondsTimeOutInterval 参数小于 -1。        [CLSCompliant(false)]        [SecuritySafeCritical]        public static RegisteredWaitHandle RegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, uint millisecondsTimeOutInterval, bool executeOnlyOnce);        //        // 摘要:        //     设置可以同时处于活动状态的线程池的请求数目。所有大于此数目的请求将保持排队状态，直到线程池线程变为可用。        //        // 参数:        //   workerThreads:        //     线程池中辅助线程的最大数目。        //        //   completionPortThreads:        //     线程池中异步 I/O 线程的最大数目。        //        // 返回结果:        //     如果更改成功，则为 true；否则为 false。        [SecuritySafeCritical]        public static bool SetMaxThreads(int workerThreads, int completionPortThreads);        //        // 摘要:        //     设置线程池在新请求预测中维护的空闲线程数。        //        // 参数:        //   workerThreads:        //     要由线程池维护的新的最小空闲辅助线程数。        //        //   completionPortThreads:        //     要由线程池维护的新的最小空闲异步 I/O 线程数。        //        // 返回结果:        //     如果更改成功，则为 true；否则为 false。        [SecuritySafeCritical]        public static bool SetMinThreads(int workerThreads, int completionPortThreads);        //        // 摘要:        //     将重叠的 I/O 操作排队以便执行。        //        // 参数:        //   overlapped:        //     要排队的 System.Threading.NativeOverlapped 结构。        //        // 返回结果:        //     如果成功地将此操作排队到 I/O 完成端口，则为 true；否则为 false。        [CLSCompliant(false)]        [SecurityCritical]        public static bool UnsafeQueueNativeOverlapped(NativeOverlapped* overlapped);        //        // 摘要:        //     将指定的委托排队到线程池，但不会将调用堆栈传播到辅助线程。        //        // 参数:        //   callBack:        //     一个 System.Threading.WaitCallback，表示当线程池中的线程选择工作项时调用的委托。        //        //   state:        //     在接受线程池服务时传递给委托的对象。        //        // 返回结果:        //     如果方法成功，则为 true；如果未能将该工作项排队，则引发 System.OutOfMemoryException。        //        // 异常:        //   T:System.Security.SecurityException:        //     调用方没有所要求的权限。        //        //   T:System.ApplicationException:        //     遇到了内存不足的情况。        //        //   T:System.OutOfMemoryException:        //     未能将该工作项排队。        //        //   T:System.ArgumentNullException:        //     callBack 为 null。        [SecurityCritical]        public static bool UnsafeQueueUserWorkItem(WaitCallback callBack, object state);        //        // 摘要:        //     注册一个等待 System.Threading.WaitHandle 的委托，并指定一个 64 位有符号整数来表示超时值（以毫秒为单位）。不将调用堆栈传播到辅助线程。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的委托。        //        //   state:        //     传递给委托的对象。        //        //   millisecondsTimeOutInterval:        //     以毫秒为单位的超时。如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。如果 millisecondsTimeOutInterval        //     为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     System.Threading.RegisteredWaitHandle 对象，可用于取消已注册的等待操作。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     millisecondsTimeOutInterval 参数小于 -1。        //        //   T:System.Security.SecurityException:        //     调用方没有所要求的权限。        [SecurityCritical]        public static RegisteredWaitHandle UnsafeRegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, long millisecondsTimeOutInterval, bool executeOnlyOnce);        //        // 摘要:        //     指定表示超时（以毫秒为单位）的 32 位无符号整数，注册一个委托等待 System.Threading.WaitHandle。不将调用堆栈传播到辅助线程。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的委托。        //        //   state:        //     传递给委托的对象。        //        //   millisecondsTimeOutInterval:        //     以毫秒为单位的超时。如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。如果 millisecondsTimeOutInterval        //     为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     System.Threading.RegisteredWaitHandle 对象，可用于取消已注册的等待操作。        //        // 异常:        //   T:System.Security.SecurityException:        //     调用方没有所要求的权限。        [CLSCompliant(false)]        [SecurityCritical]        public static RegisteredWaitHandle UnsafeRegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, uint millisecondsTimeOutInterval, bool executeOnlyOnce);        //        // 摘要:        //     注册一个等待 System.Threading.WaitHandle 的委托，并指定一个 System.TimeSpan 值来表示超时时间。不将调用堆栈传播到辅助线程。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的委托。        //        //   state:        //     传递给委托的对象。        //        //   timeout:        //     System.TimeSpan 表示的超时时间。如果 timeout 为 0（零），则函数将测试对象的状态并立即返回。如果 timeout 为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     System.Threading.RegisteredWaitHandle 对象，可用于取消已注册的等待操作。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     timeout 参数小于 -1。        //        //   T:System.NotSupportedException:        //     timeout 参数大于 System.Int32.MaxValue。        //        //   T:System.Security.SecurityException:        //     调用方没有所要求的权限。        [SecurityCritical]        public static RegisteredWaitHandle UnsafeRegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, TimeSpan timeout, bool executeOnlyOnce);        //        // 摘要:        //     注册一个等待 System.Threading.WaitHandle 的委托，并使用一个 32 位带符号整数来表示超时时间（以毫秒为单位）。不将调用堆栈传播到辅助线程。        //        // 参数:        //   waitObject:        //     要注册的 System.Threading.WaitHandle。使用 System.Threading.WaitHandle 而非 System.Threading.Mutex。        //        //   callBack:        //     waitObject 参数终止时调用的委托。        //        //   state:        //     传递给委托的对象。        //        //   millisecondsTimeOutInterval:        //     以毫秒为单位的超时。如果 millisecondsTimeOutInterval 参数为 0（零），函数将测试对象的状态并立即返回。如果 millisecondsTimeOutInterval        //     为 -1，则函数的超时间隔永远不过期。        //        //   executeOnlyOnce:        //     如果为 true，表示在调用了委托后，线程将不再在 waitObject 参数上等待；如果为 false，表示每次完成等待操作后都重置计时器，直到注销等待。        //        // 返回结果:        //     System.Threading.RegisteredWaitHandle 对象，可用于取消已注册的等待操作。        //        // 异常:        //   T:System.ArgumentOutOfRangeException:        //     millisecondsTimeOutInterval 参数小于 -1。        //        //   T:System.Security.SecurityException:        //     调用方没有所要求的权限。        [SecurityCritical]        public static RegisteredWaitHandle UnsafeRegisterWaitForSingleObject(WaitHandle waitObject, WaitOrTimerCallback callBack, object state, int millisecondsTimeOutInterval, bool executeOnlyOnce);    }}

	[SecurityCritical, SuppressUnmanagedCodeSecurity]		[DllImport("QCall", CharSet = CharSet.Unicode)]		internal static extern bool AdjustThreadsInPool(uint QueueLength);		[CLSCompliant(false), SecurityCritical]		public unsafe static bool UnsafeQueueNativeOverlapped(NativeOverlapped* overlapped)		{		}		[SecurityCritical, SuppressUnmanagedCodeSecurity]		[DllImport("QCall", CharSet = CharSet.Unicode)]		internal static extern bool ShouldUseNewWorkerPool();		[SecurityCritical, SuppressUnmanagedCodeSecurity]		[DllImport("QCall", CharSet = CharSet.Unicode)]		internal static extern bool CompleteThreadPoolRequest(uint QueueLength);		[SecurityCritical]		[MethodImpl(MethodImplOptions.InternalCall)]		internal static extern bool NotifyWorkItemComplete();		[SecurityCritical]		[MethodImpl(MethodImplOptions.InternalCall)]		internal static extern void ReportThreadStatus(bool isWorking);		[SecuritySafeCritical]		internal static void NotifyWorkItemProgress()		{		}		[SecurityCritical]		[MethodImpl(MethodImplOptions.InternalCall)]		internal static extern void NotifyWorkItemProgressNative();		[SecurityCritical, SuppressUnmanagedCodeSecurity]		[DllImport("QCall", CharSet = CharSet.Unicode)]		internal static extern bool ShouldReturnToVm();		[ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success), SecurityCritical, SuppressUnmanagedCodeSecurity]		[DllImport("QCall", CharSet = CharSet.Unicode)]		internal static extern bool SetAppDomainRequestActive();		[ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success), SecurityCritical, SuppressUnmanagedCodeSecurity]		[DllImport("QCall", CharSet = CharSet.Unicode)]		internal static extern void ClearAppDomainRequestActive();		[SecurityCritical]		[MethodImpl(MethodImplOptions.InternalCall)]		internal static extern bool IsThreadPoolHosted();		[ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success), SecurityCritical]		[MethodImpl(MethodImplOptions.InternalCall)]		internal static extern void SetNativeTpEvent();

public class CoreThreadPool : IDisposable    {        /// <summary>        /// 队列元素申明        /// </summary>        [StructLayout(LayoutKind.Sequential)]        private class PoolData        {            /// <summary>            /// 外部要求放入队列的数据            /// </summary>            public object Data;            /// <summary>            /// 需要执行的命令(Exit/Command(自定义))            /// </summary>            public CoreThreadPool.PoolCommand Command;            public PoolData()            {                this.Command = CoreThreadPool.PoolCommand.Exit;            }            public PoolData(object data)            {                this.Data = http://www.mamicode.com/data;"kernel32.dll", CharSet = CharSet.Auto, SetLastError = true)]        private static extern SafeFileHandle CreateIoCompletionPort(IntPtr FileHandle, IntPtr ExistingCompletionPort, IntPtr CompletionKey, uint NumberOfConcurrentThreads);        [DllImport("kernel32.dll", CharSet = CharSet.Auto, SetLastError = true)]        private static extern bool GetQueuedCompletionStatus(SafeFileHandle CompletionPort, out uint lpNumberOfBytesTransferred, out IntPtr lpCompletionKey, out IntPtr lpOverlapped, uint dwMilliseconds);        [DllImport("Kernel32", CharSet = CharSet.Auto)]        private static extern bool PostQueuedCompletionStatus(SafeFileHandle CompletionPort, uint dwNumberOfBytesTransferred, IntPtr dwCompletionKey, IntPtr lpOverlapped);        /// <summary>        /// 启动线程池的主线程        /// </summary>        public void Start()        {            isOpened = true;            if (thread != null)            {                throw new Exception("线程池已经是启动状态！");            }            complatePort = CreateIoCompletionPort(new IntPtr(-1), IntPtr.Zero, IntPtr.Zero, 0u);            if (complatePort.IsInvalid)            {                throw new Exception(string.Format("创建IOCP出错！原因是:{0}", Marshal.GetLastWin32Error().ToString()));            }            thread = new Thread(new ParameterizedThreadStart(this.Run));            thread.Start(complatePort);        }        /// <summary>        /// 外部提交数据对象到队列        /// </summary>        /// <param name="data"></param>        public void Post(object data)        {            PostData(new CoreThreadPool.PoolData(data));        }        /// <summary>        /// 线程池主线程执行逻辑        /// </summary>        /// <param name="CompletionPortID"></param>        private void Run(object CompletionPortID)        {            SafeFileHandle completionPort = (SafeFileHandle)CompletionPortID;                        while (IsOpened)            {                uint num;                IntPtr intPtr;                IntPtr value;                //从队列里取出最前面的对象                CoreThreadPool.GetQueuedCompletionStatus(completionPort, out num, out intPtr, out value, 4294967295u);                if (num > 0u)                {                    GCHandle gCHandle = GCHandle.FromIntPtr(value);                    CoreThreadPool.PoolData poolData = http://www.mamicode.com/(CoreThreadPool.PoolData)gCHandle.Target;"线程池已经停止。");            isOpened = false;            thread = null;        }        /// <summary>        /// 触发Execute事件        /// </summary>        /// <param name="data"></param>        private void RaiseExecute(object data)        {            Exceute?.Invoke(data);        }        /// <summary>        /// 触发ExitExecute事件        /// </summary>        /// <param name="data"></param>        private void RaiseExitExecute(object data)        {            ExitExceute?.Invoke(data);        }        /// <summary>        /// 结束线程池主线程        /// </summary>        public void Stop()        {            PostData(new PoolData(PoolCommand.Exit));            IsOpened = false;        }        /// <summary>        /// 内部提交数据到线程池队列中        /// </summary>        /// <param name="data"></param>        private void PostData(PoolData data)        {            if (complatePort.IsClosed)            {                return;            }            GCHandle value = http://www.mamicode.com/GCHandle.Alloc(data);>