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();
}
}
分享到:
相关推荐
- **JDK1.5线程并发库**:引入了更高级的并发控制机制,如`ExecutorService`、`Callable`、`Future`等,提供了更安全、更高效的多线程解决方案,减少了线程同步和死锁的风险。 ##### 2. 创建线程的两种传统方式 - ...
Semaphere同步工具可以控制通过数量有限的许可。CyclicBarrier可以实现一组线程互相等待直到某个事件发生。CountDownLatch用于一个线程等待其他线程完成各自的任务。Exchanger是两个线程交换对象的同步点。阻塞队列...
另外,Java 1.5还引入了一些高级同步工具,如**Semaphore**(信号量),用于控制同时访问特定资源的线程数量;**CyclicBarrier**(循环屏障)让一组线程等待其他线程到达一个公共屏障点,常用于多线程协作;**...
JDK 1.5引入了更多的同步工具类,如线程池`ExecutorService`,它允许更有效地管理线程,避免频繁创建和销毁线程带来的开销。`Callable`和`Future`接口提供了获取线程执行结果的能力,而`Future`的`get()`方法可以...
Java5的Exchanger同步工具 - `Exchanger`可以实现线程间的双向交换。 ##### 18. Java5阻塞队列的应用 - 阻塞队列(`BlockingQueue`)提供了一种线程安全的队列实现。 ##### 19. Java5同步集合类的应用 - 同步集合类...
- JDK:Java开发工具包,包含编译器、文档和其他开发工具。 - JRE:Java运行环境,包含JVM及运行Java程序所需的库文件。 - JVM:Java虚拟机,解释执行Java字节码。 **1.2 Java集合框架** - **List、Set与Map的...
- **JDK**:Java开发工具包,包含JRE以及编译、调试工具。 - **Java8的新特性**:Lambda表达式、Stream API、日期时间API等。 **1.2 Java常见集合** - **List和Set区别**: - **List**:有序且可重复的集合。 ...