黑马程序员技术交流社区

标题: Lock技术实现线程间通讯 [打印本页]
作者: fmi110    时间: 2015-9-30 16:40
标题: Lock技术实现线程间通讯
a
  1. package test;

  3. import java.util.concurrent.locks.Condition;
  4. import java.util.concurrent.locks.Lock;
  5. import java.util.concurrent.locks.ReentrantLock;


  8. public class Test2 {

  10.         public static void main(String[] args) throws Exception{
  11.                 final P p = new P();
  12.                 new Thread() {
  13.                         public void run() {
  14.                                 for (int i = 1; i < 11; i++) {
  15.                                                         p.show(i);                       
  16.                                 }
  17.                         };
  18.                 }.start();
  19.                 new Thread() {
  20.                         public void run() {
  21.                                 for (int i = 1; i < 11; i++) {
  22.                                                 p.print(i);                       
  23.                                 }
  24.                         };
  25.                 }.start();
  26.         }
  27. }
  28. class P {
  29.         boolean flag = false;
  30.         Lock l = new ReentrantLock();
  31.         Condition con = l.newCondition();
  32.         public void show(int i)  {
  33.                 l.lock();
  34.                 try{
  35.                         while(flag)
  36.                                 try {
  37.                                         con.await();
  38.                                 } catch (InterruptedException e) {
  39.                                         // TODO Auto-generated catch block
  40.                                         e.printStackTrace();
  41.                                 }
  42.                         System.out.println(i + "..." + Thread.currentThread().getName());
  43.                         flag = true;
  44.                 }
  45.                 finally{
  46.                         con.signalAll();
  47.                         l.unlock();
  48.                 }       
  49.         }

  51.         public void print(int i)  {
  52.                 l.lock();
  53.                 try{
  54.                         while(!flag)
  55.                                 try {
  56.                                         con.await();
  57.                                 } catch (InterruptedException e) {
  58.                                         // TODO Auto-generated catch block
  59.                                         e.printStackTrace();
  60.                                 }
  61.                         System.out.println(i + "..." + Thread.currentThread().getName());
  62.                         flag = false;
  63.                 }
  64.                 finally{
  65.                         con.signalAll();
  66.                         l.unlock();
  67.                 }       
  68.         }
  69. }
复制代码






欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2