温馨提示×

线程池ThreadPool中QueueUserWorkItem怎么使用

小亿
152
2023-11-15 13:15:17
栏目: 编程语言

QueueUserWorkItem 方法可以将工作项添加到线程池队列中,并由线程池中的一个线程执行。它接受一个 WaitCallback 委托作为参数,该委托定义了要执行的工作项的方法。

以下是使用 QueueUserWorkItem 方法的示例代码:

using System;
using System.Threading;

public class Program
{
    public static void Main()
    {
        // 创建线程池
        ThreadPool.SetMinThreads(2, 2);
        ThreadPool.SetMaxThreads(10, 10);

        // 添加工作项到线程池队列中
        ThreadPool.QueueUserWorkItem(DoWork, "WorkItem 1");
        ThreadPool.QueueUserWorkItem(DoWork, "WorkItem 2");
        ThreadPool.QueueUserWorkItem(DoWork, "WorkItem 3");

        // 等待工作项完成
        Thread.Sleep(1000);
    }

    private static void DoWork(object workItem)
    {
        Console.WriteLine($"Executing work item: {workItem}");

        // 模拟工作项的执行
        Thread.Sleep(1000);

        Console.WriteLine($"Finished work item: {workItem}");
    }
}

在上面的示例中,我们首先使用 SetMinThreadsSetMaxThreads 方法设置线程池的最小和最大线程数。然后,我们使用 QueueUserWorkItem 方法将三个工作项添加到线程池队列中。每个工作项都由线程池中的一个线程执行,执行的方法是 DoWork 方法。最后,我们使用 Thread.Sleep 方法等待所有工作项完成。

当运行上面的代码时,你将看到类似以下输出:

Executing work item: WorkItem 1
Executing work item: WorkItem 2
Finished work item: WorkItem 1
Executing work item: WorkItem 3
Finished work item: WorkItem 2
Finished work item: WorkItem 3

注意,线程池是一个共享资源,所以当其它代码也在使用线程池时,线程池的实际行为可能会有所不同。

0