如何等待所有线程

本文关键字：线程 等待 何等待 | 更新日期: 2023-09-27 18:20:29

我有创建5个线程的代码。我需要等待，直到所有线程完成它们的工作，然后返回值。我该怎么做？

public static int num=-1;
public int GetValue()
{
    Thread t=null;
    for (int i = 0; i <=5; i++)
    {
        t = new Thread(() => PasswdThread(i));
        t.Start();  
    }
    //how wait all thread, and than return value?   
    return num;
}
public void PasswdThread(int i)
{
    Thread.Sleep(1000);
    Random r=new Random();
    int n=r.Next(10);
    if (n==5)
    {
        num=r.Next(1000);
    }
}

当然，这不是一个真正的代码。实际的代码要复杂得多，所以我简化了它

附言：仔细看我没有使用Task，所以我不能使用方法Wait（）或WaitAll（）。我也不能使用Join（），因为Join只等一个线程。如果他们开始等待线程，而线程已经完成了他们的工作，那么他们将等待无穷大。

如何等待所有线程

制作如下线程数组并调用WaitAll函数

List<Thread> threads = new List<Thread>();
Thread thread = null;
 for (int i = 0; i <=5; i++)
 {
     t = new Thread(() => PasswdThread(i));
     t.Start();
     threads.add(t);
 }
Thread.WaitAll(thread);
 //how wait all thread, and than return value?  
 return num;

为每个线程创建一个ManualResetEvent句柄，然后在主线程中调用WaitHandle.WaitAll(handles)。

static WaitHandle[] handles = new WaitHandle[5];

`

public void PasswdThread(int i)
{
handles[i] = new ManualResetEvent(false);
 Thread.Sleep(1000);
 Random r=new Random();
 int n=r.Next(10);
 if (n==5)
 {
     num=r.Next(1000);
 }
 handles[i].Set();
}

获取有关的更多信息http://msdn.microsoft.com/en-us/library/z6w25xa6.aspx

我认为您可以使用Thread.WaitAll(thread_array)，或者在其他情况下也可以使用Thread.Sleep(100)

在Thread.sleep中，100是毫秒数。所以在这种情况下，线程将休眠100毫秒。

在Thread.WaitAll-thread_Array中是您想要等待的线程数组。

由于这个问题实际上是重复的，请参阅这个答案，（代码复制如下，全部归功于Reed Copsey。

class Program
{
    static void Main(string[] args)
    {
        int numThreads = 10;
        ManualResetEvent resetEvent = new ManualResetEvent(false);
        int toProcess = numThreads;
        // Start workers.
        for (int i = 0; i < numThreads; i++)
        {
            new Thread(delegate()
            {
                Console.WriteLine(Thread.CurrentThread.ManagedThreadId);
                // If we're the last thread, signal
                if (Interlocked.Decrement(ref toProcess) == 0)
                    resetEvent.Set();
            }).Start();
        }
        // Wait for workers.
        resetEvent.WaitOne();
        Console.WriteLine("Finished.");
    }
}

旁白

还要注意，PasswdThread代码不会产生随机数。Random对象应该在方法之外静态声明，以生成随机数。

此外，您永远不会使用该方法的int i参数。

我会使用TPL，因为它是处理这种同步的最新技术。考虑到现实生活中的代码可能更复杂，我将稍微修改示例：

public int GetValue()
{
    List<Task<int>> tasks = new List<Task<int>>();
    for (int i = 0; i <=5; i++)
    {
        tasks.Add(PasswdThread(i));
    }
    Task.WaitAll(tasks);
    // You can now query all the tasks:
    foreach (int result in tasks.Select(t => t.Result))
    { 
        if (result == 100) // Do something to pick the desired result...
        {
            return result;
        }
    }
    return -1;
}
public Task<int> PasswdThread(int i)
{
    return Task.Factory.StartNew(() => {
        Thread.Sleep(1000);
        Random r=new Random();
        int n=r.Next(10);
        if (n==5)
        {
            return r.Next(1000);
        }
        return 0;
    });
}

    Thread t=null;
List<Thread> lst = new List<Thread();
    for (int i = 0; i <=5; i++)
    {
         t = new Thread(() => PasswdThread(i));
         lst.Add(t);
         t.Start();  
    }
    //how wait all thread, and than return value?   
foreach(var item in lst)
{
    while(item.IsAlive)
    {
         Thread.Sleep(5);
    }
}
    return num;
相关文章：