一天一代码 ：Java线基础程通讯2
001 import java.util.concurrent.locks.* ;
002
003 class ThreadDemo2
004 {
005 ??? public static void main (String[] args)
006 ??? {
007 ??????? Resource res = new Resource ();
008
009 ??????? Producer pro = new Producer (res);
010 ??????? Consumer con = new Consumer (res);
011 ???????
012 ??????? Thread t1 =new Thread(pro);
013 ??????? Thread t2 =new Thread(pro);
014 ??????? Thread t3 =new Thread(con);
015 ??????? Thread t4 =new Thread(con);
016
017 ??????? t1.start();
018 ??????? t2.start();
019 ??????? t3.start();
020 ??????? t4.start();
021 ??? }
022 }
023
024 class Resource
025 {
026 ??? String name;
027 ??? int count = 1;
028 ??? boolean flag = false;
029 ??? private Lock lock= new ReentrantLock();
030 ??? private Condition condition_pro = lock.newCondition();
031 ??? private Condition condition_con = lock.newCondition();
032
033 ??? public void set(String name)throws InterruptedException
034 ??? {
035 ??????? lock.lock();
036 ??????? try
037 ??????? {
038 ??????????? while(flag)
039 ??????????????? condition_pro.await();
040 ??????????? this.name=name+"......"+count++;
041
042 ??????????? System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
043 ??????????? flag=true;
044 ??????????? condition_con.signal();
045 ??????? }
046 ??????? finally
047 ??????? {
048 ??????????? lock.unlock();
049 ??????? }
050
051 ??? }
052
053 ??? public void out()throws InterruptedException
054 ??? {
055 ??????? lock.lock();
056 ??????? try
057 ??????? {
058 ??????????? while(!flag)
059 ??????????????? condition_con.await();
060 ??????????? System.out.println(Thread.currentThread().getName()+"...消费者.."+this.name);
061 ??????????? flag=false;
062 ??????????? condition_pro.signal();
063 ??????? }
064 ??????? finally
065 ??????? {
066 ??????????? lock.unlock();
067 ??????? }
068 ??? }
069 }
070
071 class Producer implements Runnable
072 {
073 ??? private Resource res;
074
075 ??? Producer(Resource res)
076 ??? {
077 ??????? this.res=res;
078 ??? }
079 ??? public void run()
080 ??? {
081 ??????? while(true)
082 ??????? {
083 ??????????? try
084 ??????????? {
085 ??????????????? res.set("+商品+");
086 ??????????? }
087 ??????????? catch (InterruptedException e)
088 ??????????? {
089 ??????????? }
090 ??????? }
091 ??? }
092
093 }
094
095 class Consumer implements Runnable
096 {
097 ??? private Resource res;
098
099 ??? Consumer(Resource res)
100 ??? {
101 ??????? this.res=res;
102 ??? }
103 ??? public void run()
104 ??? {
105 ??????? while(true)
106 ??????? {
107 ??????????? try
108 ??????????? {
109 ??????????????? res.out();
110 ??????????? }
111 ??????????? catch (InterruptedException e)
112 ??????????? {
113 ??????????? }
114 ??????? }
115 ??? }
116 }
[/font]
