a.k.lysenko solution by kalin11 · Pull Request #3 · JavaLabs2025/advanced-java-2025-java-concurrency-concurrency-lab1

kalin11 · 2025-09-22T15:24:35Z

No description provided.

kalin11 · 2025-09-22T15:29:57Z

выполнил Лысенко Артём Константинович

kechinvv · 2025-09-22T19:27:35Z

src/main/java/org/labs/service/QueueService.java

+
+@Getter
+public class QueueService {
+    private final ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<>();


ConcurrentLinkedQueue это здорово, а как у вас дела с тем, что все +- одинаково поели?

Обсуждали в личке тг, но для истории продублирую - Fairness потоков достигается, тестил на 100 потоках, все примерно одинаковое количество раз запустились.
Вот параметры:

programmers_count=100 eat_count=10000 waiters_count=100 timeout_ms=10

Вот лог:

19:02:51.751 [main] INFO org.labs.Main -- Симуляция завершена. Сколько поел каждый: 19:02:51.752 [main] INFO org.labs.Main -- Программист 1 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 2 поел 102 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 3 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 4 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 5 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 6 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 7 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 8 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 9 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 10 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 11 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 12 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 13 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 14 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 15 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 16 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 17 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 18 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 19 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 20 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 21 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 22 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 23 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 24 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 25 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 26 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 27 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 28 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 29 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 30 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 31 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 32 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 33 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 34 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 35 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 36 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 37 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 38 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 39 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 40 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 41 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 42 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 43 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 44 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 45 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 46 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 47 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 48 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 49 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 50 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 51 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 52 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 53 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 54 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 55 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 56 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 57 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 58 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 59 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 60 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 61 поел 101 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 62 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 63 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 64 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 65 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 66 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 67 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 68 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 69 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 70 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 71 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 72 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 73 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 74 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 75 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 76 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 77 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 78 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 79 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 80 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 81 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 82 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 83 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 84 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 85 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 86 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 87 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 88 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 89 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 90 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 91 поел 98 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 92 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 93 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 94 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 95 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 96 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 97 поел 99 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 98 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 99 поел 100 раз 19:02:51.752 [main] INFO org.labs.Main -- Программист 100 поел 99 раз

Тестил на других коллекциях, по типу PriorityQueue - там уже Fairness отсутствует, так как нет принципа FIFO. В ней у нас выставляется приоритет в зависимости от компаратора - то есть там один поток будет обделять другие из-за наибольшего приоритета.

kechinvv · 2025-09-22T19:29:45Z

src/main/java/org/labs/Main.java

+        var foodService = new FoodService(eatCount);
+
+        var waiters = Executors.newFixedThreadPool(params.get(WAITERS_COUNT));
+        var programmers = Executors.newFixedThreadPool(params.get(PROGRAMMERS_COUNT));


Хорошо, что взяли экзекуторы, но сможете объяснить, почему именно Fixed? Может есть варианты получше? Если есть, то почему (и если нет, то тот же вопрос)?

Число потоков (программистов) заранее известно из конфига и жить эти потоки должны на протяжении всей программы, что и делает метод newFixedThreadPool

Выписка из доки:

Creates a thread pool that reuses a fixed number of threads operating off a shared unbounded queue.

Другие реализации будто бы не подходят для данной задачи. Например, cachedThreadPool более применим к короткоживущим асинхронным задачам, это не подходит под описание задачи. ScheduledThreadPool тоже не подходит, так как у нас тут нет какого-то расписания выполнения.

kechinvv · 2025-09-22T19:30:58Z

src/main/java/org/labs/io/ParamsReader.java

+    public static final String PROGRAMMERS_COUNT = "programmers_count";
+    public static final String EAT_COUNT = "eat_count";
+    public static final String WAITERS_COUNT = "waiters_count";
+    public static final String TIMEOUT_MS = "timeout_ms";


Довольно странно делать конфиг через статики -- один мисклик и все рухнет, мб лучше сделать как нибудь иначе?

Поправил на использование специального enum - org.labs.configuration.ConfigurationParam.

github-classroom bot and others added 8 commits September 14, 2025 13:27

add deadline

eec6dc8

init commit

db8338a

non-working draft

f202f2d

no deadlock, but there's problem with sync eat count

6d98726

fix peek with poll in QueueService

54ad97e

tiny refactor

afb106f

working thing

60cf979

add timeout_ms param to config

b6738c9

kalin11 changed the base branch from master to review1 September 22, 2025 15:30

kechinvv reviewed Sep 22, 2025

View reviewed changes

fix params reader

0c581a3

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

a.k.lysenko solution#3

a.k.lysenko solution#3
kalin11 wants to merge 9 commits intoreview1from
a.k.lysenko-solution

kalin11 commented Sep 22, 2025

Uh oh!

kalin11 commented Sep 22, 2025

Uh oh!

kechinvv Sep 22, 2025

Uh oh!

kalin11 Sep 23, 2025

Uh oh!

kechinvv Sep 22, 2025 •

edited

Loading

Uh oh!

kalin11 Sep 23, 2025

Uh oh!

kechinvv Sep 22, 2025

Uh oh!

kalin11 Sep 23, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Comments

Conversation

kalin11 commented Sep 22, 2025

Uh oh!

kalin11 commented Sep 22, 2025

Uh oh!

kechinvv Sep 22, 2025

Choose a reason for hiding this comment

Uh oh!

kalin11 Sep 23, 2025

Choose a reason for hiding this comment

Uh oh!

kechinvv Sep 22, 2025 • 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!

kalin11 Sep 23, 2025

Choose a reason for hiding this comment

Uh oh!

kechinvv Sep 22, 2025

Choose a reason for hiding this comment

Uh oh!

kalin11 Sep 23, 2025

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Comments

kechinvv Sep 22, 2025 •

edited

Loading