代码演示线程的wait,notify方法

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线程被唤醒后执行完剩余的线程执行体代码。

发布了236 篇原创文章 · 获赞 10 · 访问量 1万+

猜你喜欢

转载自blog.csdn.net/gunsmoke/article/details/104542330