線程轉(zhuǎn)換類Exchanger

2019-11-08 03:14:39

字體：大中小

供稿：網(wǎng)友

import java.util.concurrent.Exchanger;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * Exchanger可以在兩個(gè)線程之間交換數(shù)據(jù)，只能是2個(gè)線程，他不支持更多的線程之間互換數(shù)據(jù)。 * 當(dāng)線程A調(diào)用Exchange對(duì)象的exchange()方法后，他會(huì)陷入阻塞狀態(tài)，直到線程B也調(diào)用了exchange()方法，然后以線程安全的方式交換數(shù)據(jù)， * 之后線程A和B繼續(xù)運(yùn)行 * * @author huawangxin 2017年2月17日下午3:28:35 * */public class TestExchanger { public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final Exchanger exchanger = new Exchanger(); service.execute(new Runnable() { public void run() { try { String data1 = "zxx"; System.out.PRintln("線程" + Thread.currentThread().getName() + "正在把數(shù)據(jù)" + data1 + "換出去"); Thread.sleep((long) (Math.random() * 10000)); String data2 = (String) exchanger.exchange(data1); System.out.println("線程" + Thread.currentThread().getName() + "換回的數(shù)據(jù)為" + data2); } catch (Exception e) { } } }); service.execute(new Runnable() { public void run() { try { String data1 = "lhm"; System.out.println("線程" + Thread.currentThread().getName() + "正在把數(shù)據(jù)" + data1 + "換出去"); Thread.sleep((long) (Math.random() * 10000)); String data2 = (String) exchanger.exchange(data1); System.out.println("線程" + Thread.currentThread().getName() + "換回的數(shù)據(jù)為" + data2); } catch (Exception e) { } } }); }}

上一篇：StringUtils 工具

下一篇：SAP創(chuàng)建視圖族以及代碼，適合PL表