Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private final BlockingQueue<Runnable> executorQueue = new ArrayBlockingQueue<>(20);
- private final ThreadPoolExecutor executor = new ThreadPoolExecutor(4,4,5, TimeUnit.MINUTES, executorQueue);
- @PostConstruct
- public void startExecutor() {
- executor.prestartAllCoreThreads();
- }
- public void manageRequest(Request request) {
- log.info("Start manage request {}", request.getRequestId());
- executorQueue.add(() -> {
- // do something
- });
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement