дедлок

Вопрос по задаче

Java Multithreading, 7 уровень, 9 лекция

Решен

Я так понимаю у меня появляется дедлок. В чем проблема?

В классе TransferObject расставь вызовы методов wait/notify/notifyAll, чтобы обеспечить последовательное создание и получение объекта.
В методах run классов ConsumerTask и ProducerTask создай необходимые synchronized блоки.

Ожидаемый вывод:
...
Put: M Got: M Put: N Got: N Put: K Got: K ...
где M, N, K - числа
Метод main не участвует в тестировании

P.S. Всегда старайся использовать concurrent коллекции вместо ручной реализации wait/notify/notifyAll.
Задачи подобные этой позволяют лучше понять основы работы многопоточных приложений.

Требования:

В классе TransferObject публичный метод get() с типом возвращаемого значения int должен быть синхронизирован.
В классе TransferObject публичный метод put(int) с типом возвращаемого значения void должен быть синхронизирован.
Метод get класса TransferObject должен ждать появления value, и возвращать его после того, как оно появится.
Метод put класса TransferObject должен ждать пока value заберут и обновлять его значение после того, как оно пропадет.
Метод get класса TransferObject должен устанавливать флаг isValuePresent в false и уведомлять другие нити ожидающие освобождения монитора перед возвратом значение поля value.
Метод put класса TransferObject должен устанавливать флаг isValuePresent в true и уведомлять другие нити ожидающие освобождения монитора после обновления значение поля value.

package com.javarush.task.task27.task2709; /* Producer–consumer */ public class Solution { public static void main(String args[]) throws InterruptedException { TransferObject transferObject = new TransferObject(); ProducerTask producerTask = new ProducerTask(transferObject); ConsumerTask consumerTask = new ConsumerTask(transferObject); Thread.sleep(50); producerTask.stop(); consumerTask.stop(); } }

Комментарии (6)

популярные
новые
старые

Для того, чтобы оставить комментарий Вы должны авторизоваться

Константин Рябов

Уровень 41

14 июня 2018, 00:52

не знаю насколько актуально, у вас в методе put цикл должен идти перед ообновлением переменной, вы же должны сначало подождать и дождаться, когда измениться состояние флага, а потом обновлять. Да и в get - сначало цикл.

Ярослав Java Developer

Master

21 января 2018, 20:11

Потому что метод get класса TransferObject синхронизированный, а это тоже самое, что synchronized(this), однако объект this уже залоченный в 14 строчке класса ConsumerTask, и потому метод get ждет, когда ConsumerTask освободит его в 14 строчке.

Пётр Воронин

Уровень 40

21 января 2018, 20:40

Если убрать synchronized get и put, ничего не мменяется

Ярослав Java Developer

Master

21 января 2018, 20:48

this.notify(); и присваивание переменной надо местами поменять возможно. Просто логично, что сначала нужно что-то сделать, а потом говорить другим, что ты это сделал. А в логике

this.notify();
isValuePresent = true;

Как раз наоборот: сначала всем говорится, что переменная уже есть, а потом уже присваивается переменная.

Пётр Воронин

Уровень 40

21 января 2018, 20:54

не помогло, все так же доходит до 50-150 и блочится

Ярослав Java Developer

Master

21 января 2018, 20:59

Я бы начал тестить в Идее, но я сейчас спать буду ложиться. Сказал свои предположения, похоже мимо. Последнее предположение: когда одна нить завершается (stop), вторая нить перед проверкой значения stopped, ожидает ответа от другой нити, которая уже завершилась. Потому первая нить впадает в спячку, потому что вторая нить уже вышла из блока, потому что проверила переменную stopped, а первая еще ожидает ответа. Если и это мимо, то уже не знаю и смогу ответить только завтра, если никто не ответит раньше. И подозреваю, что с третьей попытки я, все же, попал, ведь так и есть, в методах put и get и правда должно застрять при завершении одной нити.