5

对于我来说，这是一个相对常见的任务，而且我认为对于许多 .NET 程序员来说：
我想使用 .NET ThreadPool 来调度需要处理给定类型任务的工作线程。

作为复习，ThreadPool 的队列方法及其关联委托的签名是：

public static bool QueueUserWorkItem (
    WaitCallback callBack,
    Object state
)
public delegate void WaitCallback (Object state)

因此，典型的通用工作线程类看起来像：

public class Worker<T> {
    public void schedule(T i_task) {
        ThreadPool.QueueUserWorkItem(execute, i_task)
    }
    private void execute(Object o){
        T task = (T)o;  //What happened to the type safety?  
        executeTask(task);
    }
    private void executeTask(T i_task){
        //process i_task
    }
}

注意state参数的类型？是Object！

QueueUserWorkItem.NET 团队选择不使方法（或整个ThreadPool类）通用的令人信服的原因是什么？我不敢相信他们只是忽略了它。

这是我希望看到的方式：

//in the ThreadPool class:
public static bool QueueUserWorkItem<T> (
    WaitCallback<T> callBack,
    T state
)
public delegate void WaitCallback<T> (T state)

这将使工人类类型安全（并且更清晰，恕我直言）：

public class Worker<T> {
    public void schedule(T i_task) {
        ThreadPool.QueueUserWorkItem<T>(execute, i_task)
    }
    private void execute(T i_task){
        //process i_task
    }
}

我肯定错过了什么。

4

3 回答 3

8

由于通过将匿名委托或 lambda 传递给线程池（通过变量捕获）来打包您喜欢的任何状态是微不足道的，因此不需要通用版本。

例如，您可以编写一个实用函数：

static void QueueItem<T>(Action<T> action, T state)
{
    ThreadPool.QueueUserWorkItem(delegate { action(state); });
}

但这不会非常有用，因为您可以在需要池任务中的状态的任何时候自己使用委托。

于 2008-11-27T12:00:09.367 回答
5

听起来你在谈论工作队列？（而且我听起来很笨拙……）

作为记录，线程池线程通常应该用于短的工作。理想情况下，您应该为长寿命队列创建自己的线程。请注意，.NET 4.0 可能正在采用 CCR/TPL 库，因此我们将免费获得一些内置的工作队列——但编写线程工作队列并不难。你也可以让它通用;-p

关于问题 - 我更喜欢使用捕获的变量方法将状态传递给线程（无论是Thread、ThreadPool还是Control.Invoke）：

    Thread t = new Thread(() => SomeMethod(arg));
    t.IsBackground = true;
    t.Name = "Worker n";
    t.Start();

这使您可以更精细地控制线程，而不会使ThreadPool.

于 2008-11-27T12:04:38.373 回答
1

ThreadPool 自 .NET 1.1 以来就存在，它没有泛型。

我喜欢他们选择不破坏向后兼容性的方式:-)

于 2008-11-27T14:57:48.727 回答