在多线程中创建一个类的多个实例

Question

我想知道，如何为每个线程创建单独的类实例。

例如，我有 o 使用线程处理记录集。考虑 1000 条记录和 5 个线程。每个线程应处理 200 条记录并写入 5 个文本文件。第一个线程应该写入file1，第二个线程应该写入file2，依此类推...我如何知道当前正在运行哪个线程以及如何写入正确的文件。 文件处理和数据处理在一个类中，线程调用在另一个类中。如果我创建 5 个线程，每个线程都应该有自己的类。创建第二个线程时，第一个线程将断开连接。也就是说，只有一些数据写入file1，一旦创建第二个文件，它就不会将剩余的数据写入第一个。总是最后一个文件包含所有数据，而其他文件只有很少的记录。

请帮忙。

提前致谢

Answer 1

您可能需要考虑另一种将工作拆分为线程的方法。类和线程之间没有关联，因此有很多方法可以构建代码以以多线程方式工作，我建议采用如下方法：

// Use a queue to allow the 5 threads to pull the next record
var workItems = new ConcurrentQueue<Record>();

// Add your 1000 Records to workItems queue

// Start 5 workers to process the Records in the queue
Parallel.ForEach(Enumerable.Range(0,5), index =>
{
    // Create a separate file for each thread to work with
    var fileName = string.Format("outputFile_{0}.txt", index);

    using (var outputStream = new StreamWriter(fileName))
    {
        // Dequeue Records from the queue until they're all processed
        while (!workItems.IsEmpty)
        {
            Record record;
            if (workItems.TryDequeue(out record))
            {
                // Process each record and write to the file
                var result = ProcessRecord(record);
                outputStream.Write(result);
            }
        }
    }
})