我是Spring的新手并尝试实现多线程程序 . 根据此链接中的Spring文档https://docs.spring.io/spring/docs/3.0.x/spring-framework-reference/html/scheduling.html,可以创建线程,如:
public class TaskExecutorExample {
private class MessagePrinterTask implements Runnable {
private String message;
public MessagePrinterTask(String message) {
this.message = message;
}
public void run() {
System.out.println(message);
}
}
private TaskExecutor taskExecutor;
public TaskExecutorExample(TaskExecutor taskExecutor) {
this.taskExecutor = taskExecutor;
}
public void printMessages() {
for(int i = 0; i < 25; i++) {
taskExecutor.execute(new MessagePrinterTask("Message" + i));
}
}
}
但是'Thread'是用'new'关键字创建的,而bean不是由Spring管理的 . 因此,它无法访问任何Autowired组件 . 解决此问题的方法可以是在外部类中自动装配组件并将其传递给其构造函数中的线程类 .
但是有没有其他正确的方法可以做到这一点,Spring可以负责初始化线程,以便线程可以访问所有自动连线组件 .
我正在创建的应用程序必须为从队列接收的每个新消息创建一个新线程 .
1 回答
我假设问题是关于初始化TaskExecutor并使用它的方法?!所以,文档显示了这样做的方法:
或者你可以使用
@Bean
来代码然后你可以
@Autowired
使用它 . 关于corePoolSize
,maxPoolSize
,queueCapacity
的详细信息,请参考此处:http://www.bigsoft.co.uk/blog/index.php/2009/11/27/rules-of-a-threadpoolexecutor-pool-sizeEDIT1 :在得到萨摩的澄清之后,我想将其更新为:
使用@Scope(“prototype”)将@Component添加到线程中 . 然后使用@Autowired你的线程并执行taskExecutor.execute(sampleThread)
示例在这里:https://www.mkyong.com/spring/spring-and-java-thread-example/部分:3 . Spring Thread Pool Spring托管bean示例
希望这有帮助 .