`

jdk1.5的Exchanger同步工具

阅读更多
package cn.com.songjy.test.socket.thread;

import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * 
 * ClassName:ExchangerTest
 * jdk1.5的Exchanger同步工具
 * 
 * 2个线程的数据交换模拟,形象一点的说明就是货物交换
 * @author songjy
 * @version 1.0
 * @since v1.0
 * @Date 2013-8-27 下午1:44:45
 */
public class ExchangerTest {

	private static Log log = LogFactory.getLog(ExchangerTest.class);

	public static void main(String[] args) {
		ExecutorService service = Executors.newCachedThreadPool();
		final Exchanger exchanger = new Exchanger();
		service.execute(new Runnable() {
			public void run() {
				try {

					String data = "[牛]";
					System.out.println("线程" + Thread.currentThread().getName()
							+ "正在把数据" + data + "换出去");
					Thread.sleep((long) (Math.random() * 10000));
					String data2 = (String) exchanger.exchange(data);
					log.info("线程" + Thread.currentThread().getName() + "换回的数据为"
							+ data2);
				} catch (Exception e) {
					log.error(e.getMessage(), e);
				}
			}
		});
		service.execute(new Runnable() {
			public void run() {
				try {
					String data = "[羊]";
					System.out.println("线程" + Thread.currentThread().getName()
							+ "正在把数据" + data + "换出去");
					Thread.sleep((long) (Math.random() * 10000));
					String data2 = (String) exchanger.exchange(data);
					log.info("线程" + Thread.currentThread().getName() + "换回的数据为"
							+ data2);
				} catch (Exception e) {
					log.error(e.getMessage(), e);
				}
			}
		});

		service.shutdown();
	}
}
分享到:
评论

相关推荐

    张孝祥Java多线程与并发库高级应用笔记

    - **JDK1.5线程并发库**:引入了更高级的并发控制机制,如`ExecutorService`、`Callable`、`Future`等,提供了更安全、更高效的多线程解决方案,减少了线程同步和死锁的风险。 ##### 2. 创建线程的两种传统方式 - ...

    经典Java多线程与并发库高级应用

    Semaphere同步工具可以控制通过数量有限的许可。CyclicBarrier可以实现一组线程互相等待直到某个事件发生。CountDownLatch用于一个线程等待其他线程完成各自的任务。Exchanger是两个线程交换对象的同步点。阻塞队列...

    Android多线程全新讲解[整理].pdf

    另外,Java 1.5还引入了一些高级同步工具,如**Semaphore**(信号量),用于控制同时访问特定资源的线程数量;**CyclicBarrier**(循环屏障)让一组线程等待其他线程到达一个公共屏障点,常用于多线程协作;**...

    Android多线程全新讲解.pdf

    JDK 1.5引入了更多的同步工具类,如线程池`ExecutorService`,它允许更有效地管理线程,避免频繁创建和销毁线程带来的开销。`Callable`和`Future`接口提供了获取线程执行结果的能力,而`Future`的`get()`方法可以...

    java加强笔记

    Java5的Exchanger同步工具 - `Exchanger`可以实现线程间的双向交换。 ##### 18. Java5阻塞队列的应用 - 阻塞队列(`BlockingQueue`)提供了一种线程安全的队列实现。 ##### 19. Java5同步集合类的应用 - 同步集合类...

    整理的2018 java面试汇总,要面试的抓紧看了

    - JDK:Java开发工具包,包含编译器、文档和其他开发工具。 - JRE:Java运行环境,包含JVM及运行Java程序所需的库文件。 - JVM:Java虚拟机,解释执行Java字节码。 **1.2 Java集合框架** - **List、Set与Map的...

    Java后端技术面试汇总-2019

    - **JDK**:Java开发工具包,包含JRE以及编译、调试工具。 - **Java8的新特性**:Lambda表达式、Stream API、日期时间API等。 **1.2 Java常见集合** - **List和Set区别**: - **List**:有序且可重复的集合。 ...

Global site tag (gtag.js) - Google Analytics