阅读量:0
在C#中,可以使用System.Threading.ThreadPool
类来创建和管理线程池。以下是一个简单的示例,展示了如何创建一个线程池并向其添加工作项:
using System; using System.Threading; class Program { static void Main(string[] args) { // 创建一个线程池 ThreadPool.SetMaxThreads(10, 10); // 设置线程池的最大工作线程数和最大I/O线程数 // 向线程池添加工作项 for (int i = 0; i < 5; i++) { int taskNumber = i + 1; ThreadPool.QueueUserWorkItem(new WaitCallback(Task), taskNumber); } // 等待所有工作项完成 Thread.Sleep(1000); Console.WriteLine("所有工作项已完成"); Console.ReadKey(); } // 工作项的回调方法 static void Task(object state) { int taskNumber = (int)state; Console.WriteLine($"任务 {taskNumber} 开始"); Thread.Sleep(200); // 模拟耗时操作 Console.WriteLine($"任务 {taskNumber} 结束"); } }
在这个示例中,我们首先使用ThreadPool.SetMaxThreads
方法设置线程池的最大工作线程数和最大I/O线程数。然后,我们使用ThreadPool.QueueUserWorkItem
方法向线程池添加工作项。每个工作项都是一个WaitCallback
委托,它表示要执行的任务。在这个例子中,我们将任务编号传递给Task
方法,该方法模拟一个耗时操作并输出任务开始和结束的消息。
注意:在实际应用中,通常不需要手动设置线程池的最大线程数。默认值通常适用于大多数情况。如果需要调整线程池大小,请确保根据系统资源和工作负载进行适当的调整。