使用线程池或线程

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

由于每个集合都会存储到不同的存储中，因此我不想将它们组合起来或保存到同一位置。

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

将三个线程放入线程池中。

Answer 2

使用.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 3

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

HTH