ThreadPool task by nrsxx · Pull Request #1 · nrsxx/java-tasks

nrsxx · 2017-04-22T17:05:18Z

No description provided.

DanAnastasyev

У тебя куча бинарных файлов в репозиторий попало. Почисть их и настрой gitignore

DanAnastasyev · 2017-04-22T17:53:05Z

ThreadPool/src/CustomQueue.java

@@ -0,0 +1,4 @@
+public interface CustomQueue<E> {


А зачем ты этот интерфейс создал, если потом не используешь никак?

DanAnastasyev · 2017-04-22T17:54:19Z

ThreadPool/src/MyQueue.java

+import java.util.LinkedList;
+import java.util.Queue;
+
+public class MyQueue<T> implements CustomQueue<T> {


MyQueue, конечно, очень говорящее название...

DanAnastasyev · 2017-04-22T17:55:18Z

ThreadPool/src/MyQueue.java

+import java.util.LinkedList;
+import java.util.Queue;
+
+public class MyQueue<T> implements CustomQueue<T> {


Вообще говоря, в java уже есть класс очереди, который умеет блокировать поток при отсутствии элементов

DanAnastasyev · 2017-04-22T18:01:41Z

ThreadPool/src/MyQueue.java

+    @Override
+    public synchronized void enqueue(T task) {
+        queue.add(task);
+        // Wake up anyone waiting on the queue to put some item.


Ну зачем же так палиться...

Неловко получилось, мда.
Давайте попробуем вычислить новизну кода. По моим подсчётам она (без учёта теста) составляет 11 строк (возможно, меньше). Остальные изменения являются добавленными пустыми строчками, переименованными переменными, либо переписанными комментариями.
Хватает ли 11 строк кода на то, чтобы зачесть задачу? Определённо, нет.

А за повторную попытку списывания я бы предложил запретить сдавать эту задачу. Что, кстати, довольно грустно с учётом того, что её решение является необходимым условием получения зачёта.

DanAnastasyev · 2017-04-22T18:04:20Z

ThreadPool/src/ThreadPool.java

+
+    private final int threadPoolCapacity;
+    private MyQueue<Callable> myQueue = new MyQueue();
+    private ArrayList<Thread> threads = new ArrayList();


Старайся использовать интерфейсы, а не реализации:

private CustomQueue<Callable> myQueue = new MyQueue<>(); private List<Thread> threads = new ArrayList<>();

Тогда бы появился глубинный смысл у создания интерфейса очереди

DanAnastasyev · 2017-04-22T18:05:51Z

ThreadPool/src/ThreadPool.java

+    private ArrayList<Thread> threads = new ArrayList();
+
+    private ThreadPool(int capacity) {
+        this.threadPoolCapacity = capacity;


Зачем this?

DanAnastasyev · 2017-04-22T18:06:49Z

ThreadPool/src/Task.java

+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
+
+public class Task implements Callable {


Кстати, в задании было про Runnable и реализацию определенного интерфейса

DanAnastasyev · 2017-04-22T18:08:37Z

ThreadPool/src/ThreadPool.java

+        for (int i = 0; i < threadPoolCapacity; ++i) {
+            threads.get(i).interrupt();
+        }
+        System.out.println("Good bye!");


Не надо в System.out в таком классе писать. Мало ли как он использоваться будет

DanAnastasyev · 2017-04-22T18:09:51Z

ThreadPool/src/Task.java

+        System.out.println("Начало задачи");
+        TimeUnit.SECONDS.sleep(time);
+        System.out.println("Конец задачи");
+        return null;


Зачем?

DanAnastasyev · 2017-04-22T18:11:35Z

ThreadPool/src/Task.java

+    }
+
+    @Override
+    public Object call() throws InterruptedException {


Правильнее было бы не throws InterruptedException, а обернуть sleep в try-catch

DanAnastasyev · 2017-04-27T22:02:28Z

ThreadPool/src/MyQueue.java

    @Override
    public synchronized void enqueue(T task) {
        queue.add(task);
-        // Wake up anyone waiting on the queue to put some item.


Хороший же коммент был, зачем стирать

DanAnastasyev · 2017-04-27T22:04:17Z

ThreadPool/src/ThreadPool.java

-        int num = Integer.parseInt(i.toString());//args[0]);
+        int i = 3;
+        int num = i;//args[0];
        ThreadPool threadPool = new ThreadPool(num);


Будь смелее, пиши сразу ThreadPool threadPool = new ThreadPool(3);!

DanAnastasyev · 2017-04-27T22:07:15Z

ThreadPool/src/ThreadPool.java

@@ -36,8 +36,8 @@ private void submitTask(Callable r) {

    public static void main(String... args) throws InterruptedException, ExecutionException {


Вообще говоря, обычно все пишут public static void main(String[] args). Не очень понимаю, откуда ты String... выкопал

ThreadPool task

177fef2

DanAnastasyev suggested changes Apr 22, 2017

View reviewed changes

Binary files deleted

e84a39e

DanAnastasyev reviewed Apr 27, 2017

View reviewed changes

nrsxx added 2 commits May 17, 2017 12:19

new ThreadPool

46cc686

Remove unneseccary

0d98569

		@@ -36,8 +36,8 @@ private void submitTask(Callable r) {

		public static void main(String... args) throws InterruptedException, ExecutionException {

Conversation

nrsxx commented Apr 22, 2017

Uh oh!

DanAnastasyev left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

DanAnastasyev Apr 22, 2017 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

DanAnastasyev Apr 22, 2017 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

DanAnastasyev Apr 22, 2017 •

edited

Loading

DanAnastasyev Apr 22, 2017 •

edited

Loading