您的位置:首页 > 编程语言 > Java开发

spring管理线程池

2016-05-11 16:41 162 查看
sping配置

<!-- Thread Pool -->
<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<!-- 线程池活跃的线程数 -->
<property name="corePoolSize" value="5" />
<!-- 线程池最大活跃的线程数 -->
<property name="maxPoolSize" value="10" />
<!-- 队列的最大容量 -->
<property name="queueCapacity" value="25" />
</bean>


线程

@Component("taskExecutorExample")
public class TaskExecutorExample {

@Autowired
private TaskExecutor taskExecutor;

public void printMessages() {
for (int i = 0; i < 20; i++) {
taskExecutor.execute(new MessagePrinterTask("Message" + (i+1)));
}
}

private class MessagePrinterTask implements Runnable {
private String message;

public MessagePrinterTask(String message) {
this.message = message;
}

public void run() {
//Thread.sleep(60000);抛异常
System.err.println("["+Thread.currentThread().getName()+"] message : "+message);

}
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: