使用线程池或线程

Question

我有 1 个集合，我正在将内容保存到持久存储中。然后我最终得到了 3 个我喜欢保存到持久存储中的集合。

起初我使用 ThreadPool 来保存一个集合，但现在我有 3 个集合。由于每个集合都进入不同的存储，我不想将它们组合或保存到同一个地方。

我的问题是我应该使用手动线程并为每个 Save() 方法创建一个线程，还是应该为每个方法创建 3 个线程池，还是应该在一个 ThreadPool.QueueUserWorkItem 调用中调用所有 3 个方法。

1.第一种方法

ThreadPool.QueueUserWorkItem(o => 
             { Save<Foo>(ConcurrentCollectionStorage.Bus1);
               Save<Bar>(ConcurrentCollectionStorage.Bus2);
               Save<Car>(ConcurrentCollectionStorage.Bus3);
             });

2. 第二种方法

ThreadPool.QueueUserWorkItem(o =>
               { Save<Foo>ConcurrentCollectionStorage.Bus); });  
ThreadPool.QueueUserWorkItem(o =>
               { Save<Bar>(ConcurrentCollectionStorage.Bus2); });  
ThreadPool.QueueUserWorkItem(o =>
               { Save<Car>(ConcurrentCollectionStorage.Bus3); });  

3. 第三种方法。手动创建线程并加入它们。

在执行这些操作时，我不希望我的应用程序挂起。我希望它处理和保存数据，完成，但不影响前台进程，整个应用程序。

最好的方法是什么？

我应该使用哪一个？有没有更好的方法来做到这一点？

Answer 1

使用 .NET 4.0，您可以使用任务并行库：

    Task.Factory.StartNew(() => { Save<Foo>(ConcurrentCollectionStorage.Bus1); });
    Task.Factory.StartNew(() => { Save<Bar>(ConcurrentCollectionStorage.Bus2); });
    Task.Factory.StartNew(() => { Save<Car>(ConcurrentCollectionStorage.Bus3); });

但是，您的问题并不清楚关键瓶颈是什么。如果您的瓶颈是磁盘 IO 或网络延迟，则 TPL 无法帮助您。

如果你想让你的主线程等待它们全部完成，你可以这样做（有几种方法可以做到）：

    Task t1 = Task.Factory.StartNew(() => { Save<Foo>(ConcurrentCollectionStorage.Bus1); });
    Task t2 = Task.Factory.StartNew(() => { Save<Bar>(ConcurrentCollectionStorage.Bus2); });
    Task t3 = Task.Factory.StartNew(() => { Save<Car>(ConcurrentCollectionStorage.Bus3); });

    Task.WaitAll(t1,t2,t3);

这样，运行任务的线程将等待它们完成。 t1、t2 和 t3 将异步运行。

Answer 2

如果您使用的是 .net 4，您应该使用 TASK 而不是调用 ThreadPool API。 如果您的保存操作很短，请按原样使用。如果它很长，这就是您考虑手动线程的原因，那么您应该使用任务但将其标记为“长时间运行”

HTH

Answer 3

由于每个集合都进入不同的存储，我不想将它们合并或保存到同一个地方。

在执行这些操作时，我不希望我的应用程序挂起。我希望它处理和保存数据，完成，但不影响前台进程，整个应用程序。

在线程池中排队三个线程。