2

考虑下面的代码。我不想创建多个class Waiter. （所以我不能使用 ManualResetEvent 类）

using System;
using System.Threading;

    public class Waiter
    {
        static int counter=0;
        static int max=20;

        public void Start()
        {
            for (int i = 1; i <= max; i++)
            {
                ThreadPool.QueueUserWorkItem(DoWork, (object)i);

            }
            Console.Read();//without this line the application quits before all threads are complete :(

        }

        public void DoWork(object o)
        {
            try
            {
                Thread.Sleep(1000);

            }
            finally
            {
                counter++;
                Console.WriteLine(counter);
                if (counter==max )
                {
                    Console.WriteLine("All threads complete");
                }
            }



        }

    }

    public class ThreadPoolExample
    {
        static void Main()
        {

            Waiter wtr=new Waiter();
            wtr.Start();



        }
    }

上面的代码有两个问题

1>如果 Console.Read()应用程序在所有线程结束之前退出。

2>语句 Console.WriteLine("All threads complete");执行两次。

我该如何解决？

4

2 回答 2

3

改用任务，然后你可以做Task.WaitAll(tasks);

此外，通过工厂实例化您的任务：

Task.Factory.StartNew(() => { Console.Writeline(""); });

它将为您使用线程池。

于 2012-05-25T15:35:20.980 回答
0

您应该使用Interlocked.Increment来增加counter。因为当两个线程试图同时增加它时存在竞争条件。

如果你想同时Writer工作多个实例，那么你不能有一个静态counter变量。他们会互相争斗。只需将其设为私有实例变量，就可以了。如果 Max 从不更改，则它应该是const或readonly（并保持静态），或者如果它可以更改，它也应该是一个实例字段。

最后，如果你有一个非静态ManualResetEvent实例，你可以在其中创建它Start，初始化它以设置，在循环结束时等待它，然后在最后一个线程完成时发出信号（你目前只是写到控制台）。

于 2012-05-25T16:00:44.173 回答