java.util.concurrent 之Exchanger

深碍√TFBOYSˉ_ 2022-08-07 12:59 112阅读 0赞

Exchanger类源于[Java][].util.concurrent包，它可以在两个线程之间传输数据，Exchanger中的`public V exchange(V x)`方法被调用后等待另一个线程到达交换点（如果当前线程没有被中断），然后将已知的对象传给它，返回接收的对象。更具体的说，Exchanger类允许在2个线程间定义同步点，当2个线程到达这个点，他们相互交换数据类型，使用第一个线程的数据类型变成第二个的，然后第二个线程的数据类型变成第一个的。

package com.car.test;
    
    import java.util.concurrent.Exchanger;
    
    class Car extends Thread {
    	private Exchanger<String> exchanger;
    
    	public Car(Exchanger<String> exchanger) {
    		super();
    		this.exchanger = exchanger;
    	}
    
    	@Override
    	public void run() {
    		try {
    			System.out.println(Thread.currentThread().getName() + ": " + exchanger.exchange("Car"));
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    	}
    }
    
    class Bike extends Thread {
    	private Exchanger<String> exchanger;
    
    	public Bike(Exchanger<String> exchanger) {
    		super();
    		this.exchanger = exchanger;
    	}
    
    	@Override
    	public void run() {
    		try {
    			System.out.println(Thread.currentThread().getName() + ": " + exchanger.exchange("Bike"));
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    	}
    }
    
    public class maints {
    	public static void main(String[] args) {
    
    		Exchanger<String> exchanger = new Exchanger<>();
    		Car car = new Car(exchanger);
    		Bike bike = new Bike(exchanger);
    		car.start();
    		bike.start();
    		System.out.println("Main end!");
    
    	}
    
    }

[Java]: http://lib.csdn.net/base/java