マルチスレッド例:waitとnotify、sleep
6779 ワード
package sure;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Test {
private static Logger log = LoggerFactory.getLogger(Test.class);
public static void main(String[] args) throws Exception {
final Object lock="";
Thread t1=new Thread(){
public void run(){
try {
log.info("t1 wait begin");
synchronized (lock) {
log.info("t1 get lock, wait begin");
lock.wait();
log.info("t1 wait end,release lock");
lock.notifyAll();
}
log.info("t1 wait end");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
t1.start();
log.info("t1 start and sleep");
for(int i=0;i<10000001;i++){
if(i==10000000)
log.info("i end");
}
Thread.sleep(5000);
log.info("sleep(5000) end");
log.info("main lock begin");
synchronized (lock) {
log.info("main get lock");
lock.notify();
log.info("notify");
Thread.sleep(10000);
log.info("sleep 10000 end");
log.info("main wait begin ");
lock.wait();
log.info("main wait end");
}
log.info("main lock end");
}
}
ログ情報は次のとおりです.
2011-11-09 15:44:05,968 INFO [sure.Test] - t1 start and sleep
2011-11-09 15:44:05,968 INFO [sure.Test] - t1 wait begin
2011-11-09 15:44:05,968 INFO [sure.Test] - t1 get lock, wait begin
2011-11-09 15:44:05,984 INFO [sure.Test] - i end
2011-11-09 15:44:10,984 INFO [sure.Test] - sleep(5000) end
2011-11-09 15:44:10,984 INFO [sure.Test] - main lock begin
2011-11-09 15:44:10,984 INFO [sure.Test] - main get lock
2011-11-09 15:44:10,984 INFO [sure.Test] - notify
2011-11-09 15:44:20,984 INFO [sure.Test] - sleep 10000 end
2011-11-09 15:44:20,984 INFO [sure.Test] - main wait begin
2011-11-09 15:44:20,984 INFO [sure.Test] - t1 wait end,release lock
2011-11-09 15:44:20,984 INFO [sure.Test] - t1 wait end
2011-11-09 15:44:20,984 INFO [sure.Test] - main wait end
2011-11-09 15:44:20,984 INFO [sure.Test] - main lock end
wait,notify,notifyAllは、現在のスレッドがモニタを取得したときに呼び出される必要があります.すなわち、これらのメソッドは同期ブロックで呼び出される必要があります.
ブロックされたスレッドはnotifyされた後、すぐに実行できるのではなく、「実行可能」であり、ロックを取得してから実行を開始することができます.
この例から種々の修正を行うことで,スレッドの理解を深めることができる.
package sure;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Test {
private static Logger log = LoggerFactory.getLogger(Test.class);
public static void main(String[] args) throws Exception {
final Object lock="";
Thread t1=new Thread(){
public void run(){
try {
log.info("t1 wait begin");
synchronized (lock) {
log.info("t1 get lock, wait begin");
Thread.sleep(5000);
log.info("sleep end");
lock.wait();
log.info("t1 wait end,release lock");
lock.notifyAll();
}
Thread.sleep(5000);
log.info("t1 wait end");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
t1.start();
log.info("t1 start and sleep");
log.info("main lock begin");
synchronized (lock) {
log.info("main get lock");
lock.notify();
log.info("notify");
Thread.sleep(10000);
log.info("sleep 10000 end");
log.info("main wait begin ");
lock.wait();
log.info("main wait end");
}
log.info("main lock end");
}
}
ログ:
2011-11-09 16:55:19,031 INFO [sure.Test] - t1 start and sleep
2011-11-09 16:55:19,031 INFO [sure.Test] - main lock begin
2011-11-09 16:55:19,031 INFO [sure.Test] - main get lock
2011-11-09 16:55:19,031 INFO [sure.Test] - notify
2011-11-09 16:55:19,031 INFO [sure.Test] - t1 wait begin
2011-11-09 16:55:29,031 INFO [sure.Test] - sleep 10000 end
2011-11-09 16:55:29,031 INFO [sure.Test] - main wait begin
2011-11-09 16:55:29,031 INFO [sure.Test] - t1 get lock, wait begin
2011-11-09 16:55:34,031 INFO [sure.Test] - sleep end
2つのスレッドがブロックされ、デッドロックになります.
この例は同期の使い方をさらに説明し,またThread.sleepは、現在の実行スレッドに対して使用されます.
興味深いことに、同じコードで、別の場合にこのような状況が発生します.
2011-11-09 22:06:05,930 INFO [sure.Test] - t1 start and sleep
2011-11-09 22:06:05,930 INFO [sure.Test] - t1 wait begin
2011-11-09 22:06:05,930 INFO [sure.Test] - main lock begin
2011-11-09 22:06:05,930 INFO [sure.Test] - t1 get lock, wait begin
2011-11-09 22:06:10,930 INFO [sure.Test] - sleep end
2011-11-09 22:06:10,930 INFO [sure.Test] - main get lock
2011-11-09 22:06:10,930 INFO [sure.Test] - notify
2011-11-09 22:06:20,930 INFO [sure.Test] - sleep 10000 end
2011-11-09 22:06:20,930 INFO [sure.Test] - main wait begin
2011-11-09 22:06:20,930 INFO [sure.Test] - t1 wait end,release lock
2011-11-09 22:06:20,930 INFO [sure.Test] - main wait end
2011-11-09 22:06:20,930 INFO [sure.Test] - main lock end
2011-11-09 22:06:25,930 INFO [sure.Test] - t1 wait end
この場合、デッドロックブロックは発生しません.
この2つのスレッドは、いずれも同期ブロックに先に入る可能性があるため、2つの異なる状況をもたらす.しかし、mainプロセスがsleepで遅延しているため、上記の第1のケースは、サブプロセスが同期ブロックに先に入るに違いない.