用springboot写一个线程池案例
时间: 2023-03-07 11:30:10 浏览: 89
可以参考下面这个例子:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; public class ThreadPoolExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 0; i < 10; i++) {
Runnable worker = new WorkerThread("" + i);
executor.execute(worker);
}
executor.shutdown();
while (!executor.isTerminated()) { }
System.out.println("Finished all threads");
}
} class WorkerThread implements Runnable {
private String command;
public WorkerThread(String s){
this.command=s;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+" Start. Command = "+command);
processCommand();
System.out.println(Thread.currentThread().getName()+" End.");
}
private void processCommand() {
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Override
public String toString(){
return this.command;
}
} 使用SpringBoot来实现一个线程池案例,首先需要在pom.xml中加入依赖:<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-task</artifactId>
</dependency>然后,在SpringBoot的配置文件application.yml中加入以下配置:spring:
task:
executor:
core-pool-size: 5
max-pool-size: 10
queue-capacity: 20最后,在对应的Controller中创建线程池:@Autowired
private TaskExecutor taskExecutor;public void executeThread(){
taskExecutor.execute(() -> {
//处理业务逻辑
});
}