Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- int n = 10;
- Executor executor = Executors.newFixedThreadPool(n);
- final BlockingQueue<Object> tasks = new ArrayBlockingQueue(1024);
- for (int i = 0; i < n; i++) {
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- while (!Thread.currentThread().isInterrupted()) {
- Object task = tasks.take();
- // process task
- }
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- }
- }
- });
- }
- tasks.put(new Object());
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement