zoukankan      html  css  js  c++  java
  • Java:多线程,Exchanger同步器

    1. 背景

    类java.util.concurrent.Exchanger提供了一个同步点,在这个同步点,一对线程可以交换数据。每个线程通过exchange()方法的入口提供数据给他的伙伴线程,并接收他的伙伴线程提供的数据,并返回。

    当在运行不对称的活动时很有用。比如说,一个线程向buffer中填充数据,另一个线程从buffer中消费数据;这些线程可以用Exchange来交换数据。这个交换对于两个线程来说都是安全的。

    2. 示范代码

    package com.clzhang.sample.thread;
    
    import java.util.*;
    import java.util.concurrent.Exchanger;
    
    public class SyncExchanger {
        private static final Exchanger exchanger = new Exchanger();
    
        class DataProducer implements Runnable {
            private List list = new ArrayList();
    
            @Override
            public void run() {
                for (int i = 0; i < 5; i++) {
                    System.out.println("生产了一个数据,耗时1秒");
                    list.add(new Date());
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
    
                try {
                    list = (List) exchanger.exchange(list);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                for (Iterator iterator = list.iterator(); iterator.hasNext();) {
                    System.out.println("Producer " + iterator.next());
                }
            }
        }
    
        class DataConsumer implements Runnable {
            private List list = new ArrayList();
    
            @Override
            public void run() {
                for (int i = 0; i < 5; i++) {
                    list.add("这是一个收条。");
                }
    
                try {
                    list = (List) exchanger.exchange(list);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                for (Iterator iterator = list.iterator(); iterator.hasNext();) {
                    Date d = (Date) iterator.next();
                    System.out.println("Consumer: " + d);
                }
            }
        }
    
        public static void main(String[] args) {
            SyncExchanger ins = new SyncExchanger();
            new Thread(ins.new DataProducer()).start();
            new Thread(ins.new DataConsumer()).start();
        }
    }

    输出
    生产了一个数据,耗时1秒
    生产了一个数据,耗时1秒
    生产了一个数据,耗时1秒
    生产了一个数据,耗时1秒
    生产了一个数据,耗时1秒
    Producer 这是一个收条。
    Producer 这是一个收条。
    Producer 这是一个收条。
    Producer 这是一个收条。
    Producer 这是一个收条。
    Consumer: Thu Sep 12 17:21:39 CST 2013
    Consumer: Thu Sep 12 17:21:40 CST 2013
    Consumer: Thu Sep 12 17:21:41 CST 2013
    Consumer: Thu Sep 12 17:21:42 CST 2013
    Consumer: Thu Sep 12 17:21:43 CST 2013

  • 相关阅读:
    POJ 2112 Optimal Milking (Dinic + Floyd + 二分)
    POJ 3678 Katu Puzzle (2-SAT)
    超详细的Java面试题总结(一)之Java基础知识篇
    Java高级面试题及答案
    Java线程面试题 Top 50
    Java面试题收集
    Spring基础使用(一)--------IOC、Bean的XML方式装配
    你不知道的Javascript:有趣的setTimeout
    Java 10 的 10 个新特性,将彻底改变你写代码的方式!
    深入理解 Java 多线程核心知识:跳槽面试必备
  • 原文地址:https://www.cnblogs.com/nayitian/p/3317384.html
Copyright © 2011-2022 走看看