报名电话:(0551)65867693


浅谈如何使用Exchanger实现两个线程之间的数据交互<合肥java软件培训www.hf-iflysse.com>

  1. package thread;
  2. import java.util.LinkedList;
  3. import java.util.List;
  4. import java.util.concurrent.Exchanger;
  5. /**
  6.  * 下面的例子模拟生产者生产物品 后 与消费者交换数据
  7.  * @author zhoufeng
  8.  *
  9.  */
  10. public class ExchangeDemo {
  11.     /* 如果两条线程要交换的类型是一样的 就可以为 Exchanger 加上泛型,如果不是一样的就不要加泛型 */
  12.     private final Exchanger exg = new Exchanger() ;
  13.     private class Producer implements Runnable{
  14.         List<String> list = new LinkedList<String>();
  15.         public void run() {
  16.             try {
  17.                 for (int i = 0; i < 5 ; i++) {
  18.                     String str = “producer 生产第” + i + “条数据” ;
  19.                     list.add(str) ;
  20.                 }
  21.                 System.out.println(“producer 生产完毕,等待交换数据…”);
  22.                 String result  = (String)exg.exchange(list) ;   //交换数据
  23.                 System.out.println(“producer 等待交换数据完成…”);
  24.                 // 打印消费者线程返回的消息
  25.                 System.out.println(“print by producer : 收到” + result);
  26.             } catch (InterruptedException e) {
  27.                 e.printStackTrace();
  28.             }
  29.         }
  30.     }
  31.     /* 消费者 */
  32.     private class Customer implements Runnable{
  33.         List<String> list = new LinkedList<String>();
  34.         public void run() {
  35.             try {
  36.                 Thread.sleep(5000) ;    //睡眠5s 。模拟赚钱
  37.                 System.out.println(“customer 生产完毕,等待交换数据…”);
  38.                 list = (List)exg.exchange(“5000¥”) ;    //交换数据
  39.                 System.out.println(“customer 等待交换数据完成…”);
  40.                 for (String s : list) {
  41.                     System.out.println(“print by customer : “ + s);
  42.                 }
  43.             } catch (InterruptedException e) {
  44.                 e.printStackTrace();
  45.             }
  46.         }
  47.     }
  48.     public static void main(String[] args) {
  49.         ExchangeDemo ed = new ExchangeDemo();
  50.         new Thread(ed.new Producer()).start() ;
  51.         new Thread(ed.new Customer()).start() ;
  52.     }
  53. }


您身边的IT培训专家

* * * close
预报名