Все условия выполняются, нити останавливаются ну все равно валидатор не принимает

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

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(); } }

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

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

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

Сергей Мурин

Уровень 41

21 апреля 2018, 23:07

решение

public synchronized int get()
{
    while (!isValuePresent)
    {
        try
        {
            this.wait();
        }
        catch (InterruptedException e)
        {
            e.printStackTrace();
        }
    }
    System.out.println("Got: " + value);
    isValuePresent = false;
    this.notifyAll();
    return value;
}

Это пример для оптимизации. Дальше сам :)

Юрий Агопов

Уровень 41

22 апреля 2018, 00:16

спс)

Ваня Жуков

Уровень 40

21 апреля 2018, 11:57

TransferObject криво написан.