Что-то пошло не так

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

Producer–consumer

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)

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

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

IceBerg

Уровень 41

Master

2 марта 2020, 16:27

У тебя что-то логика isValuePresent вообще перепутана.

Soros

Уровень 39

2 марта 2020, 16:48

Когда нить приходит в метод put, то если !isValuePresent, т.е. ранее положеное сюда (в TransferObject) число ещё не презентовано (ещё не забрали), то wait, пока число заберут. Приходит другая нить в метод get и проверяет, если isValuePresert == true, т.е. число презентовано (забрано), а новое ещё не принесено, то wait. Если же !isValuePresent, то не wait, а сразу работаем: - вывод в консоль (забрали, презентовали), - isValuePresent = true; //сообщили, что число презентовано, забрано - notifyAll();//активируем все ждущие потоки. - ушли. Активированный поток в методе put, проверил, что isValuePresented == true, т.е. предыдущее число презентовали, забрали, идёт дальше работать: - this.value = value;//устанавливает принесённое значение - вывод в консоль - isValuePresent = false;//вновь присвоенное значение ещё не презентовано - не забрано. - notifyAll();//активирует все ждущие нити и... - ушёл. Я так представляю логику и назначение здесь

protected volatile boolean isValuePresent = false; //use this variable

IceBerg

Уровень 41

Master

2 марта 2020, 16:50

решение

"не презентовано" и "не забрали" - это противоположные по значению вещи. isValuePresent переводится как "на месте ли вещь?"

Ksenia Volkova Java Developer в DXC

Master

2 марта 2020, 16:52

полезный

present - значит "присутствовать", а не быть презентованным

Soros

Уровень 39

2 марта 2020, 16:52

Ок. Сейчас попробую переписать.

Soros

Уровень 39

2 марта 2020, 17:23

Переписал, только не могу понять, для чего в классах продюсера и потребителя требуется синхронизация по объекту класса трансформера. Создал новую тему https://javarush.com/help/39248