以特定频率并行发送电子邮件

Question

我试图并行发送5封电子邮件.函数scheduleEmails将5个电子邮件地址列表的列表作为输入.我的代码如下所示:

import multiprocessing
import smtplib

def sendMail(email):
    #sends email using smtplib
    # returns True in case of success, False in case of failure

def scheduleEmails(emailLst):
    """
    emailLst is a list of list of 5 emails
    emailLst = [[emailAddr1,emailAddr2,emailAddr3...emailAddr5],
                [emailAddr6...emailAddr10],
                [emailAddr11... emailAddr[15],...]
    """
    FREQUENCY = 5 # no. of emails to be send per second
    for i in range(len(emailLst)):
            p = multiprocessing.Pool(FREQUENCY)
            emails = emailLst[i]
            results = p.map(sendEmail,emails)

 scheduleEmails(someEmailLst)

代码运作良好但经过一段时间后,它就会挂起.你能指出错误或提出更好的方法来实现这个目标吗？

Answer 1

你在'一段时间'后产生了多少个子过程？为了确保不使用数以万计的子进程对您的系统进行垃圾邮件,请在收集结果后显式关闭多处理池.此外,我没有在您的代码中看到任何控制frequency发送电子邮件实际的逻辑.考虑一下你有1000个电子邮件列表emailLst.您的循环将尽可能快地生成1000个多处理池,即5000个子进程.您需要实现一些时序/调度代码.在最简单的情况下,这将是time.sleep(1)你的循环.

此外,多重启动并不适合此问题,因为发送邮件不受CPU限制.我猜你的情况甚至不会受到I/O限制.您可以考虑threading将阻塞调用外包给线程而不是子进程.