java.lang.IllegalMonitorStateException:对象在wait()之前没有被线程锁定?

Ast*_*hme 41 java multithreading android

我正在使用进度dialog.i需要在用户关闭progressdialog时停止该线程.不幸的是它给出了异常请帮助我..

在内心阶级

class UpdateThread extends Thread{

    public  void run() {
        while (true){
            count=adapter.getCount();

            try {
               mHandler.post(  new Runnable() {
                    public  void run() {
                        Log.i(TAG,count+"count");
                        progressDialog.setMessage(count + "Device  found");
                    }
                });
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
Run Code Online (Sandbox Code Playgroud)

在OnCreate

 updateThread=new UpdateThread();

 progressDialog= new ProgressDialog(GroupListActivity.this);
 synchronized (this) {
     updateThread.start();
 }
Run Code Online (Sandbox Code Playgroud)

ondismissal

   progressDialog.setOnDismissListener(new DialogInterface.OnDismissListener() {
        @Override
        public  void onDismiss(DialogInterface dialog) {
            try {
                synchronized (this) {
                    updateThread.wait(300);
                }

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            Log.i(TAG,"Thread is stopped");
        }
    });
Run Code Online (Sandbox Code Playgroud)

Sol*_*low 57

这是错的:

synchronized(foo) {
    foo.wait();
}
Run Code Online (Sandbox Code Playgroud)

问题是,什么会唤醒这个线程?也就是说,第一个线程调用之前,如何保证其他线程不会调用?这很重要,因为如果首先发生通知调用,foo对象将不会记住它已被通知.如果只有一个notify(),并且它在wait()之前发生,那么wait()将永远不会返回.foo.notify() foo.wait()

以下是使用等待和通知的方式:

private Queue<Product> q = ...;
private Object lock = new Object();

void produceSomething(...) {
    Product p = reallyProduceSomething();
    synchronized(lock) {
        q.add(p);
        lock.notify();
    }
}

void consumeSomething(...) {
    Product p = null;
    synchronized(lock) {
        while (q.peek() == null) {
            lock.wait();
        }
        p = q.remove();
    }
    reallyConsume(p);
}
Run Code Online (Sandbox Code Playgroud)

在这个例子中要注意的最重要的事情是有一个显式的条件测试(即q.peek()!= null),并且没有锁定锁定没有人改变条件.

如果首先调用消费者,那么它会发现队列为空,它将等待.生产者没有时间可以进入,将产品添加到队列中,然后通知锁定,直到消费者准备好接收该通知.

另一方面,如果首先调用生产者,则保证消费者不要调用wait().

消费者中的循环很重要,原因有两个:一个是,如果有一个以上的消费者线程,那么一个消费者可能会收到一个通知,但是另一个消费者会偷偷摸摸并从队列中窃取产品.在这种情况下,第一个消费者唯一合理的做法是再次等待下一个产品.循环很重要的另一个原因是Javadoc说即使没有通知对象,也允许返回Object.wait().这被称为"虚假唤醒",处理它的正确方法是返回并再次等待.

另请注意:锁是private和队列private.这保证了其他编译​​单元不会干扰此编译单元中的同步.

请注意:锁是与队列本身不同的对象.这保证了此编译单元中的同步不会干扰Queue实现所执行的任何同步(如果有).


注意:我的例子重新发明了一个轮子以证明一个点.在实际代码中,您将使用ArrayBlockingQueue的put()和take()方法来处理所有等待和通知.


Bar*_*W19 9

如果您已经锁定了对象,则只能在对象上等待,您可以尝试:

synchronized (updateThread) {
    updateThread.wait(300);
}
Run Code Online (Sandbox Code Playgroud)

...但我不确定你想用锁来实现什么.