package com.dq;
public class ThreadTest implements Runnable
{
public static Object lock = new Object();
@Override
public void run()
{
System.out.println("进入线程执行体,当前线程名: " + Thread.currentThread().getName());
synchronized (lock)
{
System.out.println("进入同步代码块,当前线程名: " + Thread.currentThread().getName());
try
{
if (Thread.currentThread().getName().equals("thread1"))
{
System.out.println(Thread.currentThread().getName() + "线程进入等待状态,释放同步锁");
lock.wait();
}
if (Thread.currentThread().getName().equals("thread2"))
{
lock.notify();
}
}
catch (Exception e)
{
System.out.println("exception");
}
System.out.println("走出同步代码块,当前线程名: " + Thread.currentThread().getName());
}
System.out.println("走出线程执行体,当前线程名: " + Thread.currentThread().getName());
}
public static void main(String[] args) throws InterruptedException
{
ThreadTest task = new ThreadTest();
Thread thread1 = new Thread(task, "thread1");
Thread thread2 = new Thread(task, "thread2");
thread1.start();
Thread.sleep(1000);
thread2.start();
}
}
执行结果为
进入线程执行体,当前线程名: thread1
进入同步代码块,当前线程名: thread1
thread1线程进入等待状态,释放同步锁
进入线程执行体,当前线程名: thread2
进入同步代码块,当前线程名: thread2
走出同步代码块,当前线程名: thread2
走出线程执行体,当前线程名: thread2
走出同步代码块,当前线程名: thread1
走出线程执行体,当前线程名: thread1
解释一下代码的执行流程:
主线程创建了2个子线程thread1和thread2,在线程的执行体中2个线程共用一把锁,也就是lock对象,主线程中首先启动thread1线程,进入线程方法体时如果线程名为thread1则当前线程等待,也就是thread1等待,执行wait方法时释放了lock锁,此时其他线程也可以进入同步代码块了,这时又回到主线程,此时主线程执行Thread.sleep(1000)进入休眠状态,由于休眠状态后没有其它线程执行了(thread1此时处于等待状态),所以等到休眠时间到执行主线程后面的代码,此时thread2启动了,在线程方法执行体中thread2线程使用notify方法唤醒了等待lock锁的thread1对象,于是thread2线程先出线程执行体,thread1线程被唤醒后执行完剩余的线程执行体代码。