Пользовательский почтовый сервис весной - нужна помощь в улучшении

Question

У меня ниже код работает до 150 последовательных потоков.Что-нибудь по этому поводу, и сервер перестает отвечать на запросы.Пожалуйста, помогите мне с предложениями о том, как правильно интегрировать многопоточность.Я думал о ThreadPoolExecutor и ArrayBlockingQueue, но решил спросить, есть ли уже библиотека, которую я мог бы использовать, или другое решение, более подходящее для этого класса:

@Transactional
public class EmailServiceImpl implements EmailService{

private static final Logger log = Logger
        .getLogger(MailNotificationServiceImpl.class);
private JavaMailSender mailSender;
private MessageSource messageSource;
private FreeMarkerConfigurer freemarkerConfig;

public void sendEmail(final String subject, final String recipient, final ModelMap mm, final String emailTemplate, final String from) {

   try {
        MimeMessagePreparator preparator = new MimeMessagePreparator() {
            public void prepare(MimeMessage mimeMessage) throws Exception {
                MimeMessageHelper message = new MimeMeaassageHelper(

                mimeMessage);
                message.setFrom(from);
                message.setTo(recipient);
                message.setSubject(subject);

                //freemarker integration
                Template textTemplate = freemarkerConfig.getConfiguration().getTemplate(emailTemplate); // "/WEB-INF/email/*.ftl"
                log.debug(emailTemplate);
                final StringWriter textWriter = new StringWriter();
                textTemplate.process(mm, textWriter);

                message.setText(textWriter.toString(), true);
            }
        };
       Thread thread = new SendMail(preparator);
       thread.start();

    } catch (Exception e) {
        log.error(e);
    }          
}


class SendMail extends Thread {
    MimeMessagePreparator preparator;

    SendMail(MimeMessagePreparator preparator) {
        this.preparator = preparator;
    }

    public void run() {
        log.debug("About to send email:");
        mailSender.send(preparator);
        log.debug("Email send.");
    }
}



public void sendEmail(final String subject, final String recipient, final ModelMap mm, final String emailTemplate, final boolean flag, final String from) {
    if(flag){
        sendEmail(subject, recipient, mm, emailTemplate, from);
    }
}

public void sendEmail(final String subject, final String recipient, final ModelMap mm, final String emailTemplate, final boolean flag) {
    if(flag){
        sendEmail(subject, recipient, mm, emailTemplate, "support@domain.com");
    }
}    

public void sendEmail(final String subject, final String recipient, final ModelMap mm, final String emailTemplate) {
        sendEmail(subject, recipient, mm, emailTemplate, "support@domain.com");
}    

public void setMailSender(JavaMailSender mailSender) {
    this.mailSender = mailSender;
}

private String gm(String messageName) {
    return messageSource.getMessage(messageName, null, null);
}

public void setMessageSource(MessageSource messageSource) {
    this.messageSource = messageSource;
}

public void setFreemarkerConfig(FreeMarkerConfigurer freemarkerConfig) {
    this.freemarkerConfig = freemarkerConfig;
}

}

Answer 1

Вы должны рассмотреть возможность использования ExecutorService.Существует только так много параллелизма, которого вы можете достигнуть с большим количеством потоков, пока все процессоры не достигнут пика, и операционные системы не будут тратить больше времени на переключение контекста потока в / из.даже всего за 50 вы должны увидеть хорошую общую пропускную способность.

Вы можете попробовать это так:

ExecutorService executor = Executors.newFixedThreadPool(50);

public void sendEmail(final String subject, final String recipient, final ModelMap mm, final String emailTemplate, final String from) {
 MimeMessagePreparator preparator = new MimeMessagePreparator() {
       // rest of your mail building logic
      };

  executor.submit(preparator);

}