C#中如何处理线程

Question

我在我的网络应用程序中使用了线程，我在下面提到过：

var t1 = new Thread(F1);
            t1.IsBackground = true;
            t1.Start();

            var t2 = new Thread(F2);
            t2.IsBackground = true;
            t2.Start();

            var t3 = new Thread(F3);
            t3.IsBackground = true;
            t3.Start();

            var t4 = new Thread(F4);
            t4.IsBackground = true;
            t4.Start();


            t1.Join();
            t2.Join();
            t3.Join();
            t4.Join();

这工作正常并给了我所需的输出。

之后我是否需要杀死/处置线程，如果是，那么如何？ 请指导。

我已经说过，如果我不处理它，可能会引发性能问题。

Answer 1

对 Join() 的调用会取消线程分配。您无需执行任何其他操作。只需确保线程在退出之前清理它们可能正在使用的所有资源即可。

也就是说，我强烈建议您考虑使用线程池或任务并行库 (TPL)，而不是显式管理线程。它们更容易使用，处理这类事情也更顺利。

Answer 2

如果我处于你的位置，我会使用线程池而不是手动线程。它自己处理所有这些事情，并且您没有创建和销毁线程的开销。代码可能会稍微复杂一些，因为您需要使用 ManualResetEvent 而不是简单的 Thread.Join() （请参阅 如何完成 ThreadPool.Join？），但您不必担心创建太多线程，而且速度快了近 40 倍。

这是我编写的比较两种方法的测试类：

class ThreadPoolVsThreads
{
    private static readonly PerformanceMonitor threadPoolTest = new PerformanceMonitor("ThreadPoolTest");
    private static readonly PerformanceMonitor threadTest = new PerformanceMonitor("ThreadTest");

    private const int iterations = 100;
    private const int threads = 10;
    private static long somevalue;

    public static void Test()
    {
        TestHelper.PerformTest(10, threadPoolTest, ThreadPoolTest);
        TestHelper.PerformTest(10, threadTest, ThreadTest);
    }

    private static void ThreadPoolTest(int iteration)
    {
        for (int i = 0; i < iterations; i++)
        {
            var resetEvents = new ManualResetEvent[threads];
            for (int j = 0; j < threads; j++)
            {
                var re = new ManualResetEvent(false);
                resetEvents[j] = re;
                ThreadPool.QueueUserWorkItem(o =>
                {
                    somevalue++;
                    re.Set();
                });
            }
            WaitHandle.WaitAll(resetEvents);
        }
    }

    private static void ThreadTest(int iteration)
    {
        for (int i = 0; i < iterations; i++)
        {
            var threadArray = new Thread[threads];
            for (int j = 0; j < threads; j++)
            {
                var thread = new Thread(o => somevalue++);
                threadArray[j] = thread;
                thread.Start();
            }
            for (int j = 0; j < threads; j++)
            {
                threadArray[j].Join();
            }
        }
    }
}

这是五次运行的输出：

ThreadPoolTest 操作已完成：迭代 = 1，完成时间 = 53，平均完成时间 = 53.000

ThreadTest 操作已完成：迭代 = 1，完成时间 = 2128，平均完成时间 = 2128.000

ThreadPoolTest 操作已完成：迭代 = 2，完成时间 = 42，平均完成时间 = 47.500

ThreadTest 操作已完成：迭代 = 2，完成时间 = 2149，平均完成时间 = 2138.500

ThreadPoolTest 操作已完成：迭代 = 3，完成时间 = 65，平均完成时间 = 53.333

ThreadTest 操作已完成：迭代 = 3，完成时间 = 2078，平均完成时间 = 2118.333

ThreadPoolTest 操作已完成：迭代 = 4，完成时间 = 72，平均完成时间 = 58.000

ThreadTest 操作已完成：迭代 = 4，完成时间 = 2137，平均完成时间 = 2123.000

ThreadPoolTest 操作已完成：迭代 = 5，完成时间 = 43，平均完成时间 = 55.000

ThreadTest 操作已完成：迭代 = 5，完成时间 = 2085，平均完成时间 = 2115.400