有这样一道面试题目：有一个int类型的变量count，有四个线程其中两个线程对count执行count+=1一百次，另外两个线程对cout执行count-=1一百次。在程序运行过程中确保count在0到一百范围之内。这是一个典型的生产消费者问题，涉及到线程的同步和互斥操作。
public class Count { int count = 0; public synchronized void increase() { while (count == 100) try { wait();//如果count达到一百线程阻塞。 } catch (InterruptedException e) { e.printStackTrace(); } count++; notifyAll();//唤醒在此对象监视器等待的所有线程。 System.out.println("当前线程" + Thread.currentThread().getName() + count); } public synchronized void subtract() { while(count == 0) try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } count--; notifyAll(); System.out.println("当前线程" + Thread.currentThread().getName() + count); } }
public class TestThread extends Thread { TestThread(String method, String name, Count count) { super(name); this.method=method; this.count = count; } private String method; private Count count; public void run() { if (method == "increase") { for (int i = 0; i < 100; i++) { count.increase(); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } if (method == "subtract") { for (int i = 0; i < 100; i++) { count.subtract(); try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } } } } public static void main(String[] args) { Count count = new Count(); new TestThread("increase", "increaseFist", count).start(); new TestThread("increase", "increaseSecond", count).start(); new TestThread("subtract", "subtractFist", count).start(); new TestThread("subtract", "subtractSecond", count).start(); } }
以上是我写的一个实现代码。 代码很简单很容易看懂。但是还有一些问题需要注意。
一、count是临界资源需要互斥访问。
二、当count等于100或等于0时需要使当前线程等待。当调用wait方法时当前线程放弃对对象监视器。（这里的对象监视器应该是指count对象，也就是当前线程进入互斥方法时获得的对象监视器。）
三、一开始我把while（count==100）写成了if（count==100），测试结果不正确。原因是如果两个线程同时被唤醒之后，就不会在对count进行测试有可能使count超过100。
