Advertisement
Guest User

Untitled

a guest
Nov 26th, 2020
36
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 0.45 KB | None | 0 0
  1. private final BlockingQueue<Runnable> executorQueue = new ArrayBlockingQueue<>(20);
  2. private final ThreadPoolExecutor executor = new ThreadPoolExecutor(4,4,5, TimeUnit.MINUTES, executorQueue);
  3.  
  4. @PostConstruct
  5. public void startExecutor() {
  6.     executor.prestartAllCoreThreads();
  7. }
  8.  
  9. public void manageRequest(Request request) {
  10.     log.info("Start manage request {}", request.getRequestId());
  11.     executorQueue.add(() -> {
  12.         // do something
  13.     });
  14. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement