鸟语天空

执行简单的计算限制操作

作者：追风剑情 发布于：2017-7-10 22:22 分类：C#

要将一个异步的计算限制操作放到线程池的队列中，通常可以调用ThreadPool类定义的以下方法之一：

static Boolean QueueUserWorkItem(WaitCallback callBack);
static Boolean QueueUserWorkItem(WaitCallback callBack, Object state);

这些方法向线程池的队列添加一个“工作项”(work item)以及可选的状态数据。然后，所有方法会立即返回。工作项其实就是由callBack参数标识的一个方法，该方法将由线程池线程调用。可向方法传递一个state实参(状态数据)。无state参数的那个版本的QueueUserWorkItem则向回调方法传递null。最终，池中的某个线程会处理工作项，造成你指定的方法被调用。你写的回调方法必须匹配System.Threading.WaitCallback委托类型，后者的定义如下：

delegate void WaitCallback(Object state);

以下代码演示了如何让一个线程池线程以异步方式调用一个方法：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ThreadPoolTest
{
    class Program
    {
        static void Main(string[] args)
        {
            //以下代码演示了如何让一个线程池线程以异步方式调用一个方法
            Console.WriteLine("Main thread: queuing an asynchronous operation");
            ThreadPool.QueueUserWorkItem(ComputeBoundOp, 5);
            Console.WriteLine("Main thread: Doing other work here...");
            Thread.Sleep(100000);//模拟其他工作(10秒)
            Console.WriteLine("Hit <Enter> to end this program...");
            Console.ReadLine();
        }

        private static void ComputeBoundOp(Object state)
        {
            //这个方法由一个线程池线程执行

            Console.WriteLine("In ComputeBoundOp: state={0}", state);
            Thread.Sleep(1000);//模拟其他工作(1秒)

            //这个方法返回后，线程回到池中，等待另一个任务
        }
    }
}

有时也得到以下输出：
Main thread: queuing an asynchronous operation
In ComputeBoundOp: state=5
Main thread: Doing other work here...

之所以输出行的顺序会发生变化，是因为两个方法相互之间是异步运行的。Windows调度器决定先调度哪一个线程。如果应用程序在多核机器上运行，可能同时调度它们。

标签: C#