Jesus knew that they were desirous to ask him

JavaEEPRO · web-flow · commit eaf3b4680efb · 2017-12-29T16:21:32.000+02:00
Now Jesus knew that they were desirous to ask him, and said unto them, Do ye inquire among yourselves of that I said, A little while, and ye shall not see me: and again, a little while, and ye shall see me? (John 16:19)
diff --git a/Multithreading/task28/task2807/Solution.java b/Multithreading/task28/task2807/Solution.java
@@ -0,0 +1,96 @@
+
+//Now Jesus knew that they were desirous to ask him, and said unto them, Do ye inquire among yourselves of that I said, 
+//A little while, and ye shall not see me: and again, a little while, and ye shall see me? (John 16:19)
+
+package com.javarush.task.task28.task2807;
+
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+/* 
+Знакомство с ThreadPoolExecutor
+*/
+public class Solution {
+    public static void main(String[] args) throws InterruptedException {
+        LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
+        for (int i = 1; i <= 10; i++) {
+            final int finalI = i;
+            Runnable runnable = new Runnable() {
+                @Override
+                public void run() {
+                    doExpensiveOperation(finalI);
+                }
+            };
+            queue.add(runnable);
+        }
+        ThreadPoolExecutor service = new ThreadPoolExecutor(3, 5, 1000, TimeUnit.MILLISECONDS, queue);
+        service.prestartAllCoreThreads();
+        service.shutdown();
+        service.awaitTermination(5, TimeUnit.SECONDS);
+        /* output example
+pool-1-thread-2, localId=2
+pool-1-thread-3, localId=3
+pool-1-thread-1, localId=1
+pool-1-thread-3, localId=5
+pool-1-thread-2, localId=4
+pool-1-thread-3, localId=7
+pool-1-thread-1, localId=6
+pool-1-thread-3, localId=9
+pool-1-thread-2, localId=8
+pool-1-thread-1, localId=10
+         */
+    }
+
+    private static void doExpensiveOperation(int localId) {
+        System.out.println(Thread.currentThread().getName() + ", localId=" + localId);
+    }
+}
+
+/*
+Знакомство с ThreadPoolExecutor
+
+1. В методе main создай очередь LinkedBlockingQueue<Runnable>.
+
+2. В цикле добавь в очередь 10 задач Runnable.
+
+3. У каждой задачи в методе run вызови метод doExpensiveOperation с порядковым номером задачи начиная с 1, см. пример вывода.
+
+4. Создай объект ThreadPoolExecutor со следующими параметрами:
+
+- основное количество трэдов (ядро) = 3,
+
+- максимальное количество трэдов = 5,
+
+- время удержания трэда живым после завершения работы = 1000,
+
+- тайм-юнит - миллисекунды,
+
+- созданная в п.1. очередь с задачами.
+
+5. Запусти все трэды, которые входят в основное кол-во трэдов - ядро, используй метод prestartAllCoreThreads.
+
+6. Запрети добавление новых задач на исполнение в пул (метод shutdown).
+
+7. Дай объекту ThreadPoolExecutor 5 секунд на завершение всех тасок (метод awaitTermination и параметр TimeUnit.SECONDS).
+
+
+
+
+
+Требования:
+
+1. В методе main нужно создать очередь LinkedBlockingQueue.
+
+2. В цикле добавь в очередь 10 задач Runnable.
+
+3. Нужно создать объект ThreadPoolExecutor с параметрами, указанными в задании.
+
+4. С помощью метода prestartAllCoreThreads нужно запустить основные трэды.
+
+5. Каждая задача должна вызывать метод doExpensiveOperation с порядковым номером задачи, начиная с 1.
+
+6. Запрети добавление новых задач на исполнение в пул.
+
+7. На завершение всех задач в пуле нужно установить 5 секунд.
+*/
