JDK中有一个Exchanger交换类可以让两个线程的对象安全互换,注意这里是互换,而不是谁传给谁。这是一个传递字符数组的互换。
java.util.concurrent.Exchanger可以用来进行数据交换,或者被称为“数据交换器”。两个线程可以使用Exchanger交换数据,下图用来说明Exchanger的作用
从JDK 1.5之后,在java.util.concurrent包下引入了好多的处理多线程的工具类,本文介绍Exchanger工具类, 然后采用Exchanger给出一个两个线程交换数值的简单实例。
码到三十五 : 个人主页 心中有诗画,指尖舞代码,目光览世界,步履越千山,人间尽值得 !
前面三篇博客分别介绍了CyclicBarrier、CountDownLatch、Semaphore,现在介绍并发工具类中的最后一个Exchange。Exchange是最简单的也是最复杂的,简单在于API非常简单,就一个构造方法和两个exchange()方法,最复杂在于它的实现是最复杂的(反正我是看晕了的)。 在API是这么介绍的:可以在对中对元素进行配对和交换的线程的同步点。每个线程将条目上的某个方法呈现给 exchange 方法,与伙伴线程进行匹配,并且在返回时接收其伙伴的对象。Exchanger 可能被
Semaphore思想在分布式中也有应用,分布式限流就是典型的案例。现在举个小例子来使用Semaphore
在JDK1.7中,同步工具主要包括CountDownLatch(一次性栅栏)、Semaphore(信号量)、CyclicBarrier(循环同步栅栏)、Exchanger(线程间交换器)和Phaser。下面的篇幅中,将依次讲述每种同步工具的概念、用法和原理。
1. 将数据上传至 hdfs hdfs dfs -put stocks /user/bigdata 2. 创建外部表 create external table if not exists stock
Exchanger是JUC里提供的供两个线程之间交换数据或者交互的一个并发工具,API也非常简单就两个重载的exchange泛型方法。
Exchanger类是JDK5中的一个并发工具辅助类,这个类的主要作用是可以用于两个线程之间交换数据,以实际生活中的场景来讲,比如很多小区楼下都有自取的快递柜,如果快递员来了,就把东西直接放快递柜子就行了,然后我们直接从柜子中取走东西即可。这个柜子就起到了媒介的作用。也就说柜子可以是双向信息交换的一个媒介,比如我需要邮寄东西,我可以提前把东西放进柜子,然后快递来了把新买的东西放进去,然后把需要邮寄的东西拿走,这样就完成了交换,但大多数时候,我们可能买东西比较多,邮寄东西比较少。 Exchanger在遗传算法和管道设计比较有用。
Exchanger用于进行线程间的数据交换。 提供一个同步点,在这个同步点,两个线程可以交换彼此的数据。 第一个线程执行exchange方法,阻塞等待第二个线程也执行exchange方法,都到达同步点时,线程就可以交换数据 exchange(V x, long timeout, TimeUnit unit)方法可以超时等待 import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import ja
点击关注公众号,Java干货及时送达 大家好,我是栈长。 面试总结 最近栈长面试了一个 5 年经验的 Java 程序员,简历和个人介绍都提到了精通 Java 多线程,于是我就问了几个多线程方面的问题: 1、实现多线程有哪几种方式,如何返回结果? 2、多个线程如何实现顺序访问? 3、两个线程如何进行数据交换? 4、如何统计 5 个线程的运行总耗时? 5、如何将一个任务拆分成多个子任务执行,最后合并结果? 大概问了他这几个问题,答的并不是太好,3、4、5 题都没有真正答上来,其实这几个问题在 JDK 包中都有
CountDownLatch是我目前使用比较多的类,CountDownLatch初始化时会给定一个计数,然后每次调用countDown() 计数减1,
很尴尬,发了并发编程的26和27,漏了本篇25。这下子我是真的没存货了哈哈。那下面我们来补上25先,25比较短小...勿喷。
摘要: 原创出处 http://cmsblogs.com/?p=2269 「小明哥」欢迎转载,保留摘要,谢谢! 应用示例 实现分析 此篇博客所有源码均来自JDK 1.8 前面三篇博客分别介绍了Cycl
一、简介 Exchanger(交换者)是一个用于线程间协作的工具类。Exchanger用于进行线程间的数据交换。它提供一个同步点,在这个同步点两个线程可以交换彼此的数据。这两个线程通过exchange方法交换数据, 如果第一个线程先执行exchange方法,它会一直等待第二个线程也执行exchange,当两个线程都到达同步点时,这两个线程就可以交换数据,将本线程生产出来的数据传递给对方。 注:Exchanger可以在两个线程之间交换数据,只能是2个线程,他不支持更多的线程之间互换数据。 二、Exchang
在JDK的并发包里面提供了几个非常有用的并发工具,CountDownLatch、CyclicBarrier、Semaphore工具类提供了一种并发控制流程的手段,Exchanger工具类则提供了在线程间交换数据的一种手段。
有时我们需要对元素进行配对和交换线程的同步点,使用exchange方法 返回其伙伴的对象,这时我们就需要使用线程类中的Exchanger类了,
Exchanger是一个用于线程间数据交换的工具类,它提供一个公共点,在这个公共点,两个线程可以交换彼此的数据。
JUC就是java.util.concurrent包,这个包俗称JUC,里面都是解决并发问题的一些定义类,该包的位置位于java下面的rt.jar包下面。
Java并发工具类主要有CyclicBarrier、CountDownLatch、Semaphore和Exchanger,日常开发中经常使用的是CountDownLatch和Semaphore。下面就简单分析下这几个并发工具类:
java中的信号量也有很大的作用,它可以限制一个代码块可以同时被访问的线程数量(加排他锁锁可以限制只被一个线程访问),相当于流量控制。简单来说,它就是一个可以被N个线程同时占用的排它锁(因此也支持公平锁和非公平锁)。在初始时,可以指定Semaphore的许可证个数,一个线程可以获取一个或者多个许可证,当许可证不足以供其它线程获取时,想要竞争同步资源的其它线程将会被阻塞。
CountDownLatch CountDownLatch 允许一个或多个线程等待其他线程完成操作。 CountDownLatch 可以替代 join 的作用,并提供了更丰富的用法。 CountDownLatch 的 countDown 方法,N 会减1;CountDownLatch 的 await 方法会阻塞当前线程,直到 N 变成零。 CountDownLatch 不可能重新初始化或者修改 CountDownLatch 对象的内部计数器的值。 CountDownLatch 内部由 AQS 共享锁实现。
一个生产者和一个消费者通过Exchanger来交换缓冲区,以确保消费者可以不断拿到满的缓冲区,生产者不断拿到空的缓冲区.
在编程的竞技场中,多线程与并发是每一级大牛必备的技能!今天,就让我们深入了解Java并发武器库中的“五神兵”——AQS、CountDownLatch、CyclicBarrier、Semaphore、Exchanger的强大之处。他们如棋盘上的棋子,既能彼此协调,又能独当一面,解决了无数线程之问的冲突、同步与协作难题。
Phaser 是一个更加复杂和强大的同步辅助类,对 CountDownLatch 与 CyclicBarrier 的全面升级,是一个 java 并发 api 的一个重量级类。
LockSupport类:用于阻塞线程,基于线程的阻塞。而wait,notify是基于对象的,用于synchronized同步块中。 使用和原理: 浅谈Java并发编程系列(八)—— LockSupport原理剖析 使用wait/notify/notifyAll实现线程间通信的几点重要说明 AbstractQueuedSynchronizer(AQS):队列同步器,解决了同步器涉及的细节问题,如获取同步状态、FIFO同步队列。 AQS使用一个int类型的成员变量state来表示同步状态,当state>0时表示已经获取了锁,当state = 0时表示释放了锁。它提供了三个方法(getState()、setState(int newState)、compareAndSetState(int expect,int update))来对同步状态state进行操作,当然AQS可以确保对state的操作是安全的。
在实际开发中不考虑线程安全的情况下,一般不需要做线程安全处理,防止过多的处理导致性能变差
上文:AQS-semaphore&CyclicBarrier&CountDownLatch源码学习
阻塞队列:在某些情况下,会挂起线程,一旦条件满足,被挂起的线程会自动唤醒。而阻塞队列无需关心什么时候阻塞,什么时候唤醒。
Exchanger的作用是可以用来进行线程间数据的交换。线程可以调用Exchanger中的exchange()方法来交换数据。只有两个线程都调用了exchange()方法数据才会交换,如果只有一个线程执行exchange()方法,那么当前线程就会一直等待,直到有其它线程执行exchange()方法时,线程才会恢复。
CountDownLatch 线程计数器,俗称闭锁,作用是类似加强版的 Join,是让一组线程等待其他的线程完成工作以后才执行
nslookup(name server lookup)命令用于查询域名 DNS 信息的工具。nslookup 有两种工作模式,即“交互模式”和“非交互模式”。
当今互联网应用普遍需要支持高并发访问,而Java作为一种广泛使用的编程语言,其并发编程能力对于实现高性能的应用非常重要。而Java的JUC(java.util.concurrent)并发工具就提供了许多实用的工具类和接口,可以让Java应用轻松实现高效的并发编程。
同步容器。它的原理是将状态封装起来,并对每个公有方法都实行同步,使得每次只有1个线程能够访问容器的状态。
解析部分com.alibaba.dubbo.config.spring.schema.DubboBeanDefinitionParser#parse(org.w3c.dom.Element, org.springframework.beans.factory.xml.ParserContext, java.lang.Class, boolean):
最近把《java并发编程实战》-Java Consurrency in Practice 重温了一遍,把书中提到的一些常用工具记录于此: 一、闭锁(门栓)- CountDownLatch 适用场景:多线程测试时,通常为了精确计时,要求所有线程都ready后,才开始执行,防止有线程先起跑,造成不公平,类似的,所有线程执行完,整个程序才算运行完成。 /** * 闭锁测试(菩提树下的杨过 http://yjmyzz.cnblogs.com/) * * @throws Inte
await(),进入等待的状态 countDown(),计数器减一 应用场景:启动三个线程计算,需要对结果进行累加。
dnspython是python实现的一个DNS工具包,它几乎支持所有的记录类型,可以用于查询、传输病动态更新ZONE信息,同时支持TSIG(事务签名)验证消息和ENDS0(扩展DNS)。在系统管理方面,我们可以利用其查询功能来实现DNS服务监控以及解析结果的校验,可以代替nslookup、dig等工具。
用smtp发邮件挺蛋疼的,不是有配额限制就是有配额限制.所以我觉得应该有直接发送邮件的办法.回归到用命令行装逼的年代,我们是这样发信的: C:\>nslookup 默认服务器: google-public-dns-a.google.com Address: 8.8.8.8 > set type=mx > qq.com 服务器: google-public-dns-a.google.com Address: 8.8.8.8 非权威应答: qq.com MX preference = 10, mail
在前几篇文章中,我们讲到了线程、线程池、BlockingQueue 等核心组件,其实 JDK 给开发者还提供了比synchronized更加高级的线程同步组件,比如 CountDownLatch、CyclicBarrier、Semaphore、Exchanger 等并发工具类。
CountDownLatch 同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。
前面主要写了countDownLatch和cyclicBarrier的代码实例,前者是在主线程通过await等待,当所有子线程调用countDown则释放等待,cyclicBarrier则是主线程和子线程都await,所以构造参数里的值会比实际任务数量+1,并且是所有的线程到达await之后,则一起运行。
用于线程间数据的交换。它提供一个同步点,在这个同步点,两个线程可以交换彼此的数据。这两个线程通过exchange方法交换数据,如果第一个线程先执行exchange()方法,它会一直等待第二个线程也执行exchange方法,当两个线程都到达同步点时,这两个线程就可以交换数据,将本线程生产出来的数据传递给对方。
如果需要原子更新引用类型变量的话,为了保证线程安全,atomic也提供了相关的类:
JDK1.5引入了java.util.concurrent包,里边很有多有用的组件,我们挑选一些来学习
Exchange(交换器)顾名思义,它是用来实现两个线程间的数据交换的,它诞生于 JDK 1.5,它有两个核心方法:
假如有这样一个需求:我们需要解析一个Excel里多个sheet的数据,此时可以考虑使用多线程,每个线程解析一个sheet里的数据,等到所有的sheet都解析完之后,程序需要提示解析完成。在这个需求中,要实现主线程等待所有线程完成sheet的解析操作,最简单的做法是使用join()方法,如下:
闭锁的作用相当于一扇门,在这扇门没打开前,任何线程执行到这里都会被无情扣押,直到有人打开了这扇门,那些阻塞在门外的线程才会继续进行门后的流程。
可以看到,当3个信号量被领取完之后,之后的线程会阻塞在领取信号的位置,当有信号量释放之后才会继续执行。
领取专属 10元无门槛券
手把手带您无忧上云