Java的互斥技术和同步通信

在Java的多线程中，很容易出现在一个线程执行一半的时候，另一个线程获取到cpu来执行，比如银行存取款，你的银行账户有1000元，要给别人打200元，在一个线程中你获取到1000元去给别人打钱，在你还没打的时候，突然有人给你打300元钱，这时另一个线程获取到cpu给你打钱，执行完，再执行第一个线程，但此时已经获取到1000元，不是别人给你打完钱的1300元，执行完账户里有800元钱，出现混乱的情况。

这种情况可以用互斥来避免这种情况，用synchronized来实现。用一个例子来说，要在主线程和子线程中分别打印10个数，打印50次，在打印这10个数的时候不允许其他的线程打印，代码如下：

public class TraditionalThreadCommunication { public static void main(String[] args) { final Bussiness bussiness = new Bussiness(); new Thread(new Runnable() { @Override public void run() { for(int i = 0; i <= 50; i++) { bussiness.sub(i); } } }).start(); for(int i = 0; i <= 50; i++) { bussiness.main(i); } } } //要用到共同数据(包括同步锁)或共同算法的若干个方法应该归在同一个类身上， //这种设计正好体现了高内聚和程序的健壮性。 class Bussiness { public synchronized void sub(int i) { for(int j = 0; j <= 10; j++) { System.out.println("sub thread sequece of " + j + ",loop of " + i); } } public synchronized void main(int i) { for(int j = 0; j <= 10; j++) { System.out.println("main thread sequece of " + j + ",loop of " + i); } } }

而线程同步通信就比如来说在主线程和子线程交替打印10个数，打印50次，可以用wait()和notify()来实现。代码如下：

public class TraditionalThreadCommunication { public static void main(String[] args) { final Bussiness bussiness = new Bussiness(); new Thread(new Runnable() { @Override public void run() { for(int i = 0; i <= 50; i++) { bussiness.sub(i); } } }).start(); for(int i = 0; i <= 50; i++) { bussiness.main(i); } } } //要用到共同数据(包括同步锁)或共同算法的若干个方法应该归在同一个类身上， //这种设计正好体现了高内聚和程序的健壮性。 class Bussiness { private boolean bShouldSub = true; public synchronized void sub(int i) { //用while是比较两次，有时是被假唤醒，所以唤醒之后要再比较一次 while(!bShouldSub) { try { this.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } for(int j = 0; j <= 10; j++) { System.out.println("sub thread sequece of " + j + ",loop of " + i); } bShouldSub = false; //如果第一次先进入主线程的判断，主线程先等待，执行sub线程，sub线程执行完， //回到main线程执行的时候已经在wait(),不会再判断，需要先唤醒。 this.notify(); } public synchronized void main(int i) { while(bShouldSub) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } for(int j = 0; j <= 10; j++) { System.out.println("main thread sequece of " + j + ",loop of " + i); } bShouldSub = true; this.notify(); } }