Java多线程与并发应用-(4)-传统线程通信技术试题

package com.lipeng;

public class LoopDemo {

	/**
	 * 线程A循环10次，然后线程B循环100次，然后A再循环10次，然后B再循环100次。如此循环50次。
	 * lipeng
	 * 2015-4-10
	 * @param args
	 */
	public static void main(String[] args) {
		MyTask task=new MyTask();
		RunA runA=new RunA(task);
		RunB runB=new RunB(task);
		new Thread(runA,"A").start();  //每个线程的start方法只能运行一次，但Run方法在不同的线程中可以运行多次。
		new Thread(runB,"B").start();
	}
}

class RunA implements Runnable
{
	private MyTask task;
	public RunA(MyTask task)
	{
		this.task=task;
	}
	@Override
	public void run() {
		try {
			for(int i=0;i<50;i++)
			{
				task.A();
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

class RunB implements Runnable
{
	private MyTask task;
	public  RunB(MyTask task)
	{
		this.task=task;
	}
	@Override
	public void run() {
		try {
			for(int i=0;i<50;i++)
			{
				task.B();
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

class MyTask
{
	private boolean aGo=true;//切换开关，当true时A执行，false时B执行,执行完后切换条件
	public synchronized void A()throws Exception{
		while(!aGo)  //为何不用if？？？
		{
			//A 不能运行，等待
			this.wait();
		}
		for(int i=0;i<10;i++)
		{
			System.out.println("AAAAA--------------"+i);
		}
		//运行完之后，将aGo切换为FALSE，让B运行
		aGo=false;
		this.notify();//唤醒一个正在等待的线程
	}

	public synchronized void B()throws Exception{
		while(aGo)
		{
			//B 不能运行，等待
			this.wait();
		}
		for(int i=0;i<100;i++)
		{
			System.out.println("B--------------"+i);
		}
		//运行完之后，将aGo切换为true，让A运行
		aGo=true;
		this.notify();//唤醒一个正在等待的线程
	}
}

说明：

1. 如果有大于两个多线程在执行，最好用notifyAll，为什么？

例如，如果本例中多起几个线程，如果此时有A1，B1线程在wait，某个A线程执行完，将aGo置为false，并唤醒正在等待锁的其中一个线程，A1或B1，如果此时正好A1线程抢到了CPU,则A1运行，判断方法A1进入wait状态，而B1由于没有被唤醒，之后继续等待，那么到最后,A1和B1都处于wait状态，造成了死锁。

而如果改为notifyAll的话，A1和B1都被唤醒，抢到锁的线程先执行，如果A1抢到的话，继续等待，然后B1继续执行，因为此时aGo=false,所以B1执行，将aGo=true,A1继续执行完毕。

结论：只要A和B启动的线程的个数不同，就可能造成死锁的情况。

2.
判断aGo的地方为什么要使用while，if不行吗？在wait方法说明中，也推荐使用while，因为在某些特定的情况下，线程有可能被假唤醒，使用while会循环检测更稳妥。在本例中，A和B应该是交替运行的，但是如果多启动几个线程，如果有A1线程在等待（wait）状态，而A2线程执行完毕，aGo设置为false，唤醒正在等待的线程（可能是A也可能是B），如果是A被唤醒的话，如果用了if而不是while，那么A执行，这样A就连续执行了两遍，不符合我们的设计要求，但如果换用while的话，即使A被唤醒，他会再次判断aGo的值，发现是false，则继续等待。直到B线程将其唤醒。