Thread.Join 状态/突破

Question

您好，有什么方法可以从 Thread.Join 获取线程的状态，或者我可以在指定的时间段从 Thread.Join 进行突破吗？ 例如：

我有一个有 n 个作业的循环，我有 3 个空闲内核用于 3 个并行线程，在加入 3 个线程后，我想知道是否有办法检查一个线程是否完成了它的工作来启动另一个在它的地方工作。 我想让 3 个内核一直工作，而不是等待所有线程停止然后再启动另外 3 个。

Answer 1

最简单，也是最好的解决方案是使用线程池。线程池会根据可用的处理器和内核自动扩展。

ThreadPool.QueueUserWorkItem(state => TaskOne());
ThreadPool.QueueUserWorkItem(state => TaskTwo());
ThreadPool.QueueUserWorkItem(state => TaskThree());
ThreadPool.QueueUserWorkItem(state => TaskFour());

如果您需要以困难的方式执行此操作，您可以保留待处理任务的队列和当前正在运行的任务列表，并为 Join() 调用设置超时，以便它返回如果线程没有准备好，则返回 false。

我想不出任何理由更喜欢复杂的解决方案而不是简单的解决方案，但当然可能有。

var MAX_RUNNING = 3;
var JOIN_TIMEOUT_MS = 50;
var waiting = new Queue<ThreadStart>();
var running = new List<Thread>();   

waiting.Enqueue(new ThreadStart(TaskOne));
waiting.Enqueue(new ThreadStart(TaskTwo));
waiting.Enqueue(new ThreadStart(TaskThree));
waiting.Enqueue(new ThreadStart(TaskFour));


while (waiting.Any() || running.Any())
{
    while (running.Count < MAX_RUNNING && waiting.Any())
    {
        var next = new Thread(waiting.Dequeue());
        next.Start();
        running.Add(next);
    }

    for (var i = running.Count - 1; i >= 0; --i)
    {
        var t = running[i];

        if(t.ThreadState == System.Threading.ThreadState.Stopped) {
            running.RemoveAt(i);
            break;
        }

        if (t.Join(JOIN_TIMEOUT_MS))
        {
            running.RemoveAt(i);
            break;
        }
    }   
}