多线程执RabbitMQ多队列任务
系统任务是前端轮询,通过API从mq获取。
调用代码:
threadService.executeThread(new ExecuteTask());
线程池设置:
@Component
public class ThreadService{
private static ThreadPoolExecutor pool = new ThreadPoolExecutor(100, 100,
60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(200));
public void executeThread(ExecuteTask executeTask) {
pool.execute(executeTask);
}
}
ExecuteTask类具体任务是:实现Runnable接口,重写run方法,执行需要多线程跑的业务逻辑。
public class ExecuteTask implements Runnable {
@Override
public void run() {
try {
//执行业务逻辑
} catch (Exception e) {
e.printStackTrace();
}
}
}
后续完善。
版权声明:本文为sinat_41913348原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。