Java----多线程详解(三)
5、线程同步和通信
当多个线程要访问同一个资源时，有必要使这个资源一次只能让一个线程访问，这就是下面要讲到的线程同步。线程通信是指线程之间通过一些方法进行访问。
1)、线程同步的必要性
经常有这个么一种情况，当网上书店库存量还有10本书时，俩了两个人分别买7本和8本，不管哪个人先买另一个都不可能完全满足要求，因为它的库存都是不够的，下面的程序以买书为例介绍多线程同步的必要性：
public class test{ public static void main(String[] str) { ShangDian sd = new ShangDian(10); PiFa pf = new PiFa(16, sd, "批发人"); GouMai gm1 = new GouMai(8, sd, "一号"); GouMai gm2 = new GouMai(7, sd, "二号"); GouMai gm3 = new GouMai(6, sd, "三号"); gm1.start(); gm2.start(); gm3.start(); pf.start(); }}class ShangDian{ int kucun = 0; public ShangDian(int kucun) { this.kucun = kucun; } public synchronized void PiFa(int i){ kucun += i; System.out.println(Thread.currentThread().getName() + "批发" + i + "本"); notifyAll(); } public synchronized void GouMai(int i){ while (i > kucun) { try { System.out.println(Thread.currentThread().getName() + "等待"); wait(); } catch (Exception e) { e.printStackTrace(); } } kucun -= i; System.out.println(Thread.currentThread().getName() + "购买" + i + "本"); }}class PiFa extends Thread{ int i; ShangDian sd; public PiFa(int i , ShangDian sd , Stringname) { this.i = i; this.sd = sd; this.setName(name); } @Override public void run() { sd.PiFa(i); }}class GouMai extends Thread{ int i; ShangDian sd; public GouMai(int i , ShangDian sd , Stringname) { this.i = i; this.sd = sd; this.setName(name); } @Override public void run() { sd.GouMai(i); }}其中一种运行结果为：
一号购买8本
二号等待
三号等待
批发人批发16本
三号购买6本
二号购买7本
本程序中，其实库存有10本，一号运行后买了8本。库存还有2本，这时二号三号分别购买7本和6本，库存不够，系统会调用wait()方法，使它们处于等待状态。然后调用管理员线程，批发16本，这时库存有18本，然后管理员线程调用notifyAll()方法通知处于等待状态中的二号三号。线程二号三号接到通知后进入运行状态，分别购买。