3

我希望你们能容忍我在线程的情况下完全缺乏方向。我必须实现一个邮件队列处理系统，我必须通过 Windows 服务发送在数据库中排队的电子邮件。

它不是生产者-消费者模式。我一次将 10 行数据提取到数据表中。数据表包含序列化的 MailMessage 对象和 SMTP 发送详细信息。如果我必须使用固定数量的线程（比如 6 个线程）现在我将如何从线程中的数据表中获取一行，然后发送邮件并再次返回以查看是否还有更多行？

任何实现这一点的简单逻辑都可以，最好使用 C# 中的简单示例。

我正在使用 .NET 3.5

4

2 回答 2

6

由于发送电子邮件是一个 I/O 绑定过程，因此生成线程来发送电子邮件不会实现太多（如果有的话）加速。

如果您使用的是属于 Windows 的 SMTP 服务器，那么当您“发送”一封电子邮件时，它实际上并没有在那个时刻被发送。它位于服务器上的队列中，服务器尽可能快地发送它们。发送电子邮件实际上是一个缓慢的过程。

我想我要说的是有两种选择：

  1. 只需按顺序发送它们，看看是否满足您的性能要求。
  2. 您可以使用称为“数据并行”的并行编程概念，我在博客文章Data Parallel – Parallel Programming in C#/.NET

基本上，您所做的是，您将获得所有数据（一口气）。原因是批量获取数据也会减慢您的流程，因此如果您对性能感兴趣（这就是我猜您尝试使用线程的原因），那么不要对数据库服务器进行多次往返（这也是两个级别的 I/O 绑定，网络 I/O 和磁盘 I/O）。

因此，获取您的数据，并将其拆分为块或分区。这一切都在我指出的文章中进行了解释。天真的实现是块的数量等于机器上的核心数量。

每个块由一个线程处理。当所有线程都完成后，你就完成了。借助 .NET 4.0 中 ThreadPool 的新功能（如果您使用 Parallel.For 或 PLINQ 或 Tasks），您将获得一些其他好处，例如“工作窃取”以进一步加快工作速度。

我认为 Parallel.For/Parallel.ForEach 对你很有效。

编辑

刚刚注意到 .NET 3.5 的要求。好吧，这些概念仍然适用，但您没有 Parallel.For/ForEach。所以这是一个使用 ThreadPool 并使用数据并行技术的实现（根据我的博客文章修改）。

    private static void SendEmailsUsingThreadPool(List<Recipient> recipients)
    {
      var coreCount = Environment.ProcessorCount;
      var itemCount = recipients.Count;
      var batchSize = itemCount / coreCount;

      var pending = coreCount;
      using (var mre = new ManualResetEvent(false))
      {
        for (int batchCount = 0; batchCount < coreCount; batchCount++)
        {
          var lower = batchCount * batchSize;
          var upper = (batchCount == coreCount - 1) ? itemCount : lower + batchSize;
          ThreadPool.QueueUserWorkItem(st =>
          {
            for (int i = lower; i < upper; i++)
              SendEmail(recipients[i]);
            if (Interlocked.Decrement(ref pending) == 0)
              mre.Set();
          });
        }
        mre.WaitOne();
      }      
    }

    private static void SendEmail(Recipient recipient)
    {
      //Send your Emails here
    }
  }

  class Recipient
  {
    public string FirstName { get; set; }
    public string LastName { get; set; }
    public string EmailAddress { get; set; }
  }

因此，获取您的数据并调用 SendEmailUsingThreadPool() 将您的数据传递给它。当然不要这样称呼你的方法:)。如果您有 DataSet/DataTable，则只需修改实现以接受 DataSet/DataTable。这种方法负责将您的数据分成块，因此您不必担心任何这些。简单地调用它。

于 2011-02-24T09:56:42.663 回答
0

您需要在一个地方将消息提取到内存中，然后将它们路由到不同的线程。我猜

于 2011-02-24T09:32:20.400 回答