多线程的运用

1.spring整合线程池

---

<context:property-placeholder location="classpath:resource/*.properties" />

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">

<property name="corePoolSize" value="${task.core_pool_size}" />

<property name="maxPoolSize" value="${task.max_pool_size}" />

<property name="queueCapacity" value="${task.queue_capacity}" />

<property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
</bean>

<task:annotation-driven />

---

2.关于properties的配置

---

task.core_pool_size=5
task.max_pool_size=50
task.queue_capacity=1000
task.keep_alive_seconds=60

---

3.代码的写法

---

①注入taskExecutor
@Resource(name = "taskExecutor")
private TaskExecutor taskExecutor;
②写一个方法
例如发送邮件
public void sendMail(Message msg, String[] userIds, Attach attach)
throws MessagingException, UnsupportedEncodingException {

    MimeMessage email = javaMailSender.createMimeMessage();
    MimeMessageHelper helper = new MimeMessageHelper(email, true, "utf-8");
    // 从哪里发送
    helper.setFrom("");
    // 发送给谁
    helper.setTo("");
    // 发送题目
    helper.setSubject("");

    if (CompusUtil.isNotEmpty(attach)) {

        File[] attFiles = attach.getAttFiles();
        String[] fns = attach.getAttfilename();
        for (int i = 0; i < attFiles.length; i++) {
            File file = attFiles[i];
            String fnsString = fns[i];
            helper.addAttachment(MimeUtility.encodeText(fnsString),
                    new FileSystemResource(fnsString));
        }
    }

    helper.setText(msg.getContent(), true);// 添加消息内容，html设置为true

    javaMailSender.send(email);// 发出邮件
}

③创建一个sendmailThread类调用②中的方法
private class sendMailThread implements Runnable {

    private Message msg;
    private String[] userIds;
    private Attach attach;
    //创建构造方法
    public sendMailThread(Message msg, String[] userIds, Attach attach) {
        super();
        this.msg = msg;
        this.userIds = userIds;
        this.attach = attach;
    }

    @Override
    public void run() {
        
        try {
        //此处调用了sendMail方法
            sendMail(msg,userIds,attach);
        } catch (UnsupportedEncodingException | MessagingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
}

④通过taskExcecutor执行 线程
public int txAddMessage(Message msg,String[] userIds,Attach attach) {

    taskExecutor.execute(new sendMailThread(msg,userIds,attach));
    return 0;
}

---