Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private void cronJob(long interval) {
- ExecutorService executor = Executors.newFixedThreadPool(50);
- CompletionService<ArrayList<Element>> compService = new ExecutorCompletionService<>(executor);
- for (Task task : tasks) {
- compService.submit((Callable<ArrayList<Element>>) task);
- }
- for (Task task : tasks) {
- Future<ArrayList<Element>> future = compService.take();
- ArrayList<Element> list = future.get();
- for (Element e : list) {
- e.update();
- }
- }
- executor.shutdown();
- executor.awaitTermination(Long.MAX_VALUE , TimeUnit.NANOSECONDS);
- //Wait for interval period and repeat
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement