用 Task 控制线程答案

【问题标题】：Control threads with Task用 Task 控制线程
【发布时间】：2011-05-25 11:29:56
【问题描述】：

在一些这样的代码中

for (int i = 0; i < length; i++) //each iteration in another task
{
     Method2();

}
//Task.WaitAll()

public void Method2()
{
    Method3();
}

public void Method3()
{
    Method4();
}

public void Method4()
{
    process1.Start(); //this process take a lot of time so next iteration/next task should start in this place
}

我想在其他线程中运行每个迭代，但不是一次。一个线程应该转到 Method4()，运行它，然后等待结束这个进程。稍后另一个具有相同行为的线程等。并且在 Task.WaitAll() 程序中应该等待所有线程。

如何做到这一点？一次迭代中的 2 个任务，ContinueWith 还是 sth？

【问题讨论】：

您遗漏了 Method1，Method2 出现了两次。还要指出是否/在哪里有任何 CPU 密集型处理。

标签： c# multithreading .net-4.0 parallel-processing multitasking

【解决方案1】：

不要打扰。

所有迭代很快都会执行 Method4() 并且您想要那个单线程。

在这种约束下，这根本不是任务或线程的场景。

但假设在 Method2() 和/或 Method3() 中发生了一些实质性的事情，您可以将 for() 循环替换为 Parallel.For() 并在 Process 代码周围使用简单的 lock：

private static object processLock = new object();  // probably static

public void Method4()
{
   lock(processLock)
   {
       process1.Start(); 
   }
}

但是现在您必须防止 TPL 创建太多线程。（在 Parallel.For 中使用 DegreeOfParallelism）。

【讨论】：

不，process1 需要将近 1 小时，所以我想运行它几次以更好地利用处理器
那么也许可以更好地解释“不是一次全部”部分？并在 MethodX 在这里没有功能时移除。

【解决方案2】：

如果我理解正确，您想并行运行所有这些进程，但您想限制同时运行的进程数对吗？为此，您可以使用限制并发性的信号量（但请注意，所有线程都将一直处于挂起状态 - 因此将它们标记为 LongRunning）。

另一件事是您必须在 Method4 中等待进程退出。

static SemaphoreSlim semaphore = new SemaphoreSlim (3); // Capacity of 3

List<Task> tasks = new List<Task>();
for (int i = 0; i < length; i++) //each iteration in another task
{
     tasks.Add(Task.Factory.StartNew(() =>
     {
         Method2();
     }, 
     TaskCreationOptions.LongRunning);
}
Task.WaitAll(tasks)

public void Method2()
{
    Method3();
}

public void Method3()
{
    Method4();
}

public void Method4()
{
    semaphore.Wait();
    process1.Start(); 
    process1.WaitForExit();
    semaphore.Release();
}

【讨论】：