Как использовать ожидание и уведомление в Java без IllegalMonitorStateException? - PullRequest
Новая
       98

Как использовать ожидание и уведомление в Java без IllegalMonitorStateException?

126 голосов
/ 20 мая 2009

У меня есть 2 матрицы, и мне нужно умножить их, а затем распечатать результаты каждой ячейки. Как только одна ячейка готова, мне нужно напечатать ее, но, например, мне нужно напечатать ячейку [0] [0] перед ячейкой [2] [0], даже если результат [2] [0] готов первым , Поэтому мне нужно распечатать его по заказу. Поэтому моя идея состоит в том, чтобы заставить поток принтера ждать, пока multiplyThread не уведомит его о том, что правильная ячейка готова к печати, а затем printerThread напечатает ячейку и вернется к ожиданию и т. Д.

Итак, у меня есть этот поток, который делает умножение: 

public void run() 
{
    int countNumOfActions = 0; // How many multiplications have we done
    int maxActions = randomize(); // Maximum number of actions allowed

    for (int i = 0; i < size; i++)
    {       
        result[rowNum][colNum] = result[rowNum][colNum] + row[i] * col[i];
        countNumOfActions++;
        // Reached the number of allowed actions
        if (countNumOfActions >= maxActions)
        {
            countNumOfActions = 0;
            maxActions = randomize();
            yield();
        }   
    }
    isFinished[rowNum][colNum] = true;
    notify();
}

Поток, который печатает результат каждой ячейки: 

public void run()
{
    int j = 0; // Columns counter
    int i = 0; // Rows counter
    System.out.println("The result matrix of the multiplication is:");

    while (i < creator.getmThreads().length)
    {
        synchronized (this)
        {
            try 
            {
                this.wait();
            } 
            catch (InterruptedException e1) 
            {
            }
        }
        if (creator.getmThreads()[i][j].getIsFinished()[i][j] == true)
        {
            if (j < creator.getmThreads()[i].length)
            {
                System.out.print(creator.getResult()[i][j] + " ");
                j++;
            }
            else
            {
                System.out.println();
                j = 0;
                i++;
                System.out.print(creator.getResult()[i][j] + " ");
            }
        }
    }

Теперь мне выдаются следующие исключения: 

Exception in thread "Thread-9" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-6" Exception in thread "Thread-4" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-5" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-8" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-7" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-11" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-10" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)
Exception in thread "Thread-12" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at multiplyThread.run(multiplyThread.java:49)

строка 49 в multiplyThread - это "notify ()" .. Я думаю, что мне нужно использовать синхронизированный по-другому, но я не уверен, как.

Если кто-нибудь сможет помочь этому коду работать, я буду очень признателен.

Ответы [ 12 ]

0 голосов
/ 06 ноября 2014

Это похоже на ситуацию для модели производитель-потребитель. Если вы используете Java 5 или более позднюю версию, вы можете рассмотреть возможность использования очереди блокировки (java.util.concurrent.BlockingQueue) и оставить работу по координации потоков для базовой реализации framework / api. Смотрите пример из Java 5: http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/BlockingQueue.html или Java 7 (тот же пример): http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html

0 голосов
/ 01 июня 2014

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

Страница:
...