0

我的脚本为用户列表发送电子邮件。我需要多线程，因为 1 个地址中的错误会使所有应用程序崩溃。这是我的实现：

  require 'thread'
  <...>
  lock = Mutex.new
  lock.synchronize {
    @model.certs.each{ |user|
      @threads << Thread.new(user) { |data|
      to = "#{data['name']} #{data['surname']} <#{data['email']}>"
      subject = '<Subject>'
      body = "<Body>"
      view = View.new()
      view.to = to
      view.body = body
      view.subject = subject
      view.attachment = ''
      view.sendMessage()
      @model.sended(data['email'])
      }
    }
  }

  @threads.each { |t|
    begin
      t.join
    rescue => err
      $log.fatal(err)
    end
  }

view.sendMessage包括：

require 'mail'
require 'net/smtp'
<...>
smtp = Net::SMTP.start(@mailserver)
mail = Mail.new()
mail.from = @from
mail.to = @to
mail.subject = @subject
mail.body = @body
if !@attachment.empty?
  mail.add_file @attachment
end
mail.delivery_method :smtp_connection, {
  :connection => smtp
}
mail.deliver

有时它会出现以下错误：

uninitialized constant Mail::Field::FromField (NameError)
/var/lib/gems/1.8/gems/mail-2.4.4/lib/mail/field.rb:189:in `new_field'

或者

uninitialized constant Mail::CommonAddress::AddressList (NameError)
/var/lib/gems/1.8/gems/mail-2.4.4/lib/mail/fields/common/common_address.rb:9:in `parse'

我不知道，如何解决。互斥量添加没有结果。

4

2 回答 2

2

Require 在 ruby​​ 中不是线程安全的。您应该确保在开始线程之前已经需要您需要的一切。

此外，您的互斥锁目前没有做任何事情。虽然多线程非常适合发送电子邮件等可能受网络延迟支配的活动，但我不会说错误处理是使用多线程的理由（如果有的话）。

于 2013-05-06T15:56:17.653 回答
0

@FrederickCheung 关于线程中的 require 是正确的。此外，你真的需要线程吗？出什么问题了：

emails.each do |mail|
  begin
    mail.deliver
  rescue TheCorrectExceptionForInvalidEmails
    puts "invalid e-mail: x"
    method_to_remove_invalid_email_from_database
  end
end

即使您让一个空块进行救援，在一封无效的电子邮件中，它也会跳转并继续执行。

于 2013-05-06T15:59:49.030 回答