IllegalMonitorStateException on wait() call

Question

Я использую многопоточность в java для своей программы. У меня успешно работает поток, но когда я использую Thread.wait(), он бросает java.lang.IllegalMonitorStateException. Как я могу сделать поток до тех пор, пока он не будет уведомлен?

Answer 1

Чтобы работать, вам необходимо находиться в блоке synchronized для того, чтобы работать Object.wait().

Кроме того, я рекомендую посмотреть пакеты параллелизма вместо старых пакетов потоковой передачи в школах. Они безопаснее и способнее easier to work with.

Счастливое кодирование.

EDIT

Я предположил, вы имели в виду Object.wait(), как ваше исключение это то, что происходит, когда вы пытаетесь получить доступ, не держа блокировки объектов.

Answer 2

Поскольку у вас еще нет кода, мы работаем в темноте. Каковы детали исключения?

Вы вызываете Thread.wait() из потока или вне его?

Я спрашиваю это потому, что в соответствии с Javadoc для IllegalMonitorStateException, это:

Брошенный, чтобы указать, что поток пытается ждать на мониторе объекта или уведомить другие потоки, ожидающие на мониторе объекта без владеющий указанным монитором.

Чтобы прояснить этот ответ, этот призыв ждать на нитку и бросает IllegalMonitorStateException, несмотря на то, вызывается из синхронизированного блока:

    private static final class Lock { } 
    private final Object lock = new Lock(); 

    @Test 
    public void testRun() { 
     ThreadWorker worker = new ThreadWorker(); 
     System.out.println ("Starting worker"); 
     worker.start(); 
     System.out.println ("Worker started - telling it to wait"); 
     try { 
      synchronized (lock) { 
       worker.wait(); 
      } 
     } catch (InterruptedException e1) { 
      String msg = "InterruptedException: [" + e1.getLocalizedMessage() + "]"; 
      System.out.println (msg); 
      e1.printStackTrace(); 
      System.out.flush(); 
     } 
     System.out.println ("Worker done waiting, we're now waiting for it by joining"); 
     try { 
      worker.join(); 
     } catch (InterruptedException ex) { } 

    } 

Answer 3

wait определяется в Object, а не его Thread. Монитор на Thread немного непредсказуем.

Хотя все объекты Java имеют мониторы, как правило, лучше иметь специальный замок:

private final Object lock = new Object(); 

Вы можете получить немного легче читать диагностику, при небольших затратах памяти (около 2K в процессе), используя именованный класс:

private static final class Lock { } 
private final Object lock = new Lock(); 

для wait или notify/notifyAll объекта, вам нужно удерживать блокировку с synchronized заявления. Кроме того, вам понадобится цикл while, чтобы проверить состояние пробуждения (найдите хороший текст для потоковой передачи, чтобы объяснить, почему).

synchronized (lock) { 
    while (!isWakeupNeeded()) { 
     lock.wait(); 
    } 
} 

Сообщать:

synchronized (lock) { 
    makeWakeupNeeded(); 
    lock.notifyAll(); 
} 

Это хорошо стоит того, чтобы понять, как Java, язык и java.util.concurrent.locks замки (и java.util.concurrent.atomic) при получении в многопоточности.Но используйте структуры данных java.util.concurrent всякий раз, когда сможете.

Answer 4

вызов Thread.wait() имеет смысл внутри кода, который синхронизируется с объектом Thread.class. Я не думаю, что это то, что вы имели в виду.
Вы спрашиваете

Как я могу сделать нить ждать, пока он не будет уведомлен?

Вы можете сделать только текущий поток. Любой другой поток может быть только мягко просят подождать, если он согласен.
Если вы хотите подождать какое-то условие, вам нужен объект блокировки. Объект Thread.class - очень плохой выбор - это синглтон AFAIK, поэтому синхронизация на нем (за исключением статических методов Thread) опасна.
Детали для синхронизации и ожидания уже объяснены Томом Хотином. java.lang.IllegalMonitorStateException означает, что вы пытаетесь подождать объекта, на котором вы не синхронизированы, - это незаконно.

Answer 5

на основе ваших комментариев это звучит, как вы делаете что-то вроде этого:

Thread thread = new Thread(new Runnable(){ 
    public void run() { // do stuff }}); 

thread.start(); 
... 
thread.wait(); 

Есть две проблемы. Во-первых, как говорили другие, obj.wait() можно вызывать только в том случае, если текущая нить содержит примитивный мьютекс для obj. Если текущий поток не поддерживает мьютекс, вы получаете исключение, которое вы видите.

Вторая (более важная) проблема заключается в том, что thread.wait() не делает то, что вы, похоже, ожидаете от нее. В частности, thread.wait()не заставляют номинированную нить ждать. Скорее он вызывает текущий поток, чтобы ждать, пока какой-либо другой поток не вызовет thread.notify() или thread.notifyAll().

На самом деле нет безопасного способа заставить экземпляр Thread останавливаться, если он этого не хочет. (Ближайшей к этому Java является устаревший метод Thread.suspend(), но этот метод по своей сути является небезопасным, как объясняется в Javadoc.)

Если вы хотите, чтобы недавно начатая нить приостанавливалась, лучший способ сделать это для создания экземпляра CountdownLatch и вызова потока await() на защелку для приостановки. Затем основной поток вызовет countDown() на защелку, чтобы продолжить приостановленный поток.

Answer 6

Я знаю, что этот поток почти 2 лет, но все еще нужно, чтобы закрыть это, так как я пришел к этому Q/A сессии с тем же вопросом ...

Пожалуйста, прочтите это определение illegalMonitorException снова и снова .. .

IllegalMonitorException выбрасывается, чтобы указать, что поток попытался подождать на мониторе объекта или уведомить другие потоки, ожидающие монитора объекта, не владея указанным монитором.

Эта линия снова и снова говорит, IllegalMonitorException приходит, когда один из 2 ситуации происходит ....

1> ждать на мониторе объекта, не имея указанного монитора.

2> уведомлять другие потоки, ожидающие наблюдения на объекте, не обладая указанным монитором.

Некоторые могли бы получили свои ответы ... которые все же не так, то пожалуйста, проверьте 2 заявления ....

синхронизирована (объект)

Object.wait()

Если оба Объект такие же ... тогда никакое незаконное исключениеMonitorException может прийти.

Теперь снова прочитать определение IllegalMonitorException и вы не будете забывать это снова ...

Answer 7

Не уверен, если это поможет кому-то еще или нет, но это была ключевая часть, чтобы исправить мою проблему пользователя «Tom Hawtin - tacklin " 's ответ выше:

synchronized (lock) { 
    makeWakeupNeeded(); 
    lock.notifyAll(); 
} 

просто тот факт, что„блокировки“передается в качестве аргумента в синхронизирована() и она также используется в„замок“.notifyAll();

После того, как я сделал это в этих 2 местах я получил это работает

Answer 8

я получил IllegalMonitorStateException, пытаясь разбудить нить в/из другого class/нить. В java 8 вы можете использовать lock features of the new Concurrency APIвместо из synchronized функций.

Я уже хранил объекты для asynchronous транзакций websocket в WeakHashMap. Решение в моем случае было также store a lock object in a ConcurrentHashMap для synchronous ответов. Примечаниеcondition.await (не .wait).

Для обработки многопоточности я использовал Executors.newCachedThreadPool() для создания thread pool.

Answer 9

Те, кто использует Java 7.0 или ниже, могут ссылаться на код, который я использовал здесь, и он работает.

public class WaitTest { 

    private final Lock lock = new ReentrantLock(); 
    private final Condition condition = lock.newCondition(); 

    public void waitHere(long waitTime) { 
     System.out.println("wait started..."); 
     lock.lock(); 
     try { 
      condition.await(waitTime, TimeUnit.SECONDS); 
     } catch (InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     lock.unlock(); 
     System.out.println("wait ends here..."); 
    } 

    public static void main(String[] args) { 
     //Your Code 
     new WaitTest().waitHere(10); 
     //Your Code 
    } 

}