多线程和分配数组到c中的每个线程＃

Question

我正在编写向多个用户发送电子邮件的代码。我必须根据用户信息更换邮件内容。由于用户数量很大，我想要多个线程发送邮件来修复用户数量。所以我想创建线程并为每个线程分配一个指定用户信息的数组。我该怎么做？

int noOfThread = noOfUsers/5000; 
    private IList<Thread> threadList = new List<Thread>(); 
    for(int i=0; i<noOfThread; i++) 
    { 
     Thread thread = new thread(FunctionToCall); 
     thread.IsBackground = true; 
     thread.Name = threadSendMail + i; 
     threadList.Add(thread); 
     thread.Start(); 
    } 

如何分配数组到每个线程并传递给函数FunctionToCall（）？

Answer 1

我的建议是，在所有不使用线程现在是过时与TPL（任务并行库）的地方，你的代码必须是这样的：

Parallel.Foreach(UserList, user => 
{ 
// Do Email send action here, you can modify details per user here 
} 
); 

或

Parallel.For(0, noOfThread, user => 
    { 
    // Do Email send action here, you can modify details per user here 
    } 
    ); 

好处是巨大的：

• 它会做CPU核心优化，并将分配基于可用性TY。它会根据环境/逻辑内核等进行运行时优化。

• 您不需要根据上面的静态公式决定创建线程的数量，这不会导致任何优化，并且会像一个尺寸适合所有

  int noOfThread = noOfUsers/5000; 
  

即使你想申请然后一些这样的公式在Environment.ProcessorCount这将按照系统中的处理器数量变化带来的，但仍然它不是运行时优化和可用性。

• 并行API在内部使用ThreadPool，这对于这样的场景来说更好，因为线程是一个昂贵的资源，并且您希望它们从池中重用，而不是创建和销毁。每个线程的默认堆栈分配为1 MB，并且您不希望内存只分配和销毁，而不能通过池重用。

Answer 2

也许在这种情况下，您可以使用BlockingCollection？

例如

_collection = new BlockingCollection<List<UserInfo>>(); //BlockingCollection contains list of 5000 user for example 

var consumer = Task.Factory.StartNew(() => 
{ 
    Parallel.ForEach(Partitioner.Create(_collection.GetConsumingEnumerable()), new ParallelOptions() { MaxDegreeOfParallelism = 10}, (partOfCollection) => 
    { 
     DoSomethingWithList(partOfCollection); //in this function you loop the list of userinfo and run the 'FunctionToCall' method 
    } 
} 

//Add users in blocks of 5000 to the collection 
_collection.Add(firstPartOfUserInfo); 
_collection.Add(secondPartOfUserInfo); 

_collection.CompleteAdding(); 

consumer.Wait(); 

我不知道如果我写到这里的代码会为你工作，但是这是我使用在多个不同线程块巨大的名单。