c# - 暂停一个线程直到一个方法和里面的所有线程完成他们的工作？

Question

我是线程的新手，我想知道如何使用它们在非确定性有限自动机中进行评估。

我有调用另一个方法的方法:

public bool Evaluate2(string s)
{
    accepted = false;

    ThreadEval(s, StartState);            

    return accepted; 
}

变量 accepted 是一个类成员，我用它来控制其他线程何时应该停止。

void ThreadEval(string s, State q)
{            
    if (s.Length == 0 && q.IsFinal)
    {
        accepted = true;
        return;
    }

    bool found = true;            
    State current = q;

    for (int i = 0; found && !accepted && i < s.Length; i++)
    {
        found = false;
        foreach (Transition t in current.transitions)
            if (t.symbol == s[i])
            {
                Thread thread = new Thread(new ThreadStart(delegate { ThreadEval(s.Substring(i+1), t.to); }));
                thread.Start();
                found = true;
            }
     }
}

我的每个状态都有一组转换。转换由一个符号和它可以通过使用该符号进入的状态组成。因此，每当找到可能的转换时，我都想创建一个新线程并检查字符串的其余部分(不包括当前字符)...

我目前有 2 个问题:

• 在 ThreadEval 中创建的所有线程完成之前，正在执行“接受返回”。有没有办法确保它在这些线程完成之前不会返回？我在返回之前放了一个 Thread.Sleep(200) 并且它起作用了，但是 200 毫秒对于大字符串来说可能不够，而且我也不想提高该值，所以小字符串将花费比处理它们更长的时间.

• 目前的代码导致了一些索引异常...我 99.999% 确定它是正确的，但只有当我调用传递值 < 的子字符串时它才会停止崩溃b> i 而不是 i + 1 ... 但是如果我只调用 i 它永远不会到达字符串的末尾并且取决于自动机配置可能会导致无限循环。我不确切知道线程是如何工作的，但我怀疑可能某些并行处理在子字符串切片之前改变了 i 的值。我如何确保无论何时调用新线程，我都只会丢弃当前字符？

如果有人对如何更优雅地使用线程有任何建议，我将不胜感激，到目前为止，我发现在线程分配给的函数中传递参数的唯一方法是使用委托(delegate)。

Answer 1

为了阻塞直到一个线程t执行完成，你可以使用 Thread.Join .

t.Join();

这会使主线程处于空闲状态，直到线程 t完成。这意味着您必须跟踪 foreach 中创建的所有线程。循环然后将它们一一加入。

更好的方法是使用 TPL 的 Task<T>而不是直接使用线程。你的代码会有点像这样:

Task ThreadEval(string s, State q)
{
    //...

    List<Task> tasks = new List<Task>();

    for (int i = 0; found && !accepted && i < s.Length; i++)
    {
        found = false;
        foreach (Transition t in current.transitions)
            if (t.symbol == s[i])
            {
                tasks.Add(
                    Task.Run(
                        () => await ThreadEval(s.Substring(i+1), t.to)));
                found = true;
            }
     }

    return Task.WhenAll(tasks);
}

await ThreadEval(...);

1. 更改签名以返回 Task而不是无效
2. 创建所有正在运行的任务的列表
3. Task.WhenAll将创建一个新任务，当 tasks 中的所有 任务时，该任务将被标记为完成列表本身被标记为完整。返回这个任务。

然后调用者将await ThreadEval.