The grace of our Lord Jesus Christ be with you all

JavaEEPRO · web-flow · commit 42a037c852f8 · 2017-12-27T12:10:29.000+02:00
The grace of our Lord Jesus Christ be with you all. Amen. (Revelation 22:21)
diff --git a/Multithreading/task29/trask2905/Solution.java b/Multithreading/task29/trask2905/Solution.java
@@ -0,0 +1,120 @@
+
+//The grace of our Lord Jesus Christ be with you all. Amen. (Revelation 22:21)
+
+package com.javarush.task.task29.task2905;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+/* 
+Странные ошибки О_о
+*/
+public class Solution {
+    final int NUMBER_OF_THREADS = 3; //3 треда будет обрабатывать нашу очередь
+    final int MAX_BATCH_SIZE = 100; //будем вытаскивать по 100 сообщений
+
+    private Logger logger = Logger.getLogger(Solution.class.getName());
+    private BlockingQueue messageQueue = new LinkedBlockingQueue();//тут будут храниться все сообщения
+
+    private BlockingQueue fakeDataBase = new LinkedBlockingQueue();
+
+    public static void main(String[] args) throws InterruptedException {
+        // статики во многих местах неуместны, поэтому помещаем все данные в поля класса,
+        // затем создаем объект и вызываем его метод
+        Solution solution = new Solution();
+
+        solution.startMessageCreating();
+        solution.startMessagePersisting();
+
+        Thread.sleep(100);
+        solution.printResults();
+
+        Thread.sleep(100);
+        solution.printResults();
+
+        Thread.sleep(100);
+        solution.printResults();
+
+        Thread.sleep(500);
+        solution.printResults();
+    }
+
+    public void startMessageCreating() {
+        new Thread() {
+            @Override
+            public void run() {
+                for (int i = 0; i < 100000; i++) {
+                    messageQueue.add(String.valueOf(i));
+                }
+            }
+        }.start();
+    }
+
+    public void startMessagePersisting() {
+        for (int i = 0; i < NUMBER_OF_THREADS; i++) {
+            new Thread() {
+                private final Collection batch = new ArrayList(MAX_BATCH_SIZE);
+
+                {
+                    setDaemon(true);
+                }
+
+                @Override
+                public void run() {
+                    while (true) {
+                        try {
+                            messageQueue.drainTo(batch, MAX_BATCH_SIZE);
+                            persistData(batch);
+                            batch.clear();
+                            Thread.sleep(1);
+                        } catch (Throwable e) {
+                            logger.log(Level.SEVERE, "impossible to persist a batch", e);
+                        }
+                    }
+                }
+            }.start();
+        }
+    }
+
+    private void persistData(Collection batch) {
+        //представим, что тут мы коннектимся к базе данных, и сохраняем данные в нее
+        //сохранение данных по 1 записи тратит много ресурсов, поэтому делают батчем (группой по несколько)
+        fakeDataBase.addAll(batch);
+    }
+
+    private void printResults() {
+        System.out.println();
+        System.out.println("messageQueue size is " + messageQueue.size());
+        System.out.println("fakeDataBase size is " + fakeDataBase.size());
+    }
+}
+
+/*
+Странные ошибки О_о
+
+Исправь 2 ошибки:
+
+1) возникновение исключения
+
+2) подвисание
+
+Сделай минимальные изменения.
+
+
+
+
+
+Требования:
+
+1. Метод startMessageCreating должен без зависаний добавлять в messageQueue 100000 элементов.
+
+2. Исправь ошибку в строке "messageQueue.drainTo(messageQueue, MAX_BATCH_SIZE);".
+
+3. Метод main не должен зависать.
+
+4. Вывод программы должен показывать, что все сообщения из messageQueue были перенесены в fakeDataBase.
+*/
