package future;

import java.util.Date;

/**

* 服務(wù)器

*

* @author wpy

*

*/

public class Service {

/**

* 1.服務(wù)器的處理某個(gè)業(yè)務(wù)，該業(yè)務(wù)可以分成AB兩個(gè)過程，并且AB兩個(gè)過程之間不需要彼此的返回結(jié)果

* 2.A過程需要1秒鐘，B過程需要2秒鐘，主線程其他操作2秒鐘

*

* @param args

* @throws InterruptedException

*/

public static void main(String[] args) throws InterruptedException {

Service service = new Service();

long notUseFuture = service.notUseFuture();

System.out.println("==============================");

long useFuture = service.useFuture();

System.out.println("==============================");

System.out.println("notUseFuture整個(gè)業(yè)務(wù)耗時(shí)"+notUseFuture);

System.out.println("useFuture整個(gè)業(yè)務(wù)耗時(shí)"+useFuture);

}

public long useFuture() throws InterruptedException {

Date startOn = new Date();

String name = Thread.currentThread().getName();

final FutureDate futureDateA = new FutureDate<>();

final FutureDate futureDateB = new FutureDate<>();

Thread a = new Thread(new Runnable() {

@Override

public void run() {

String name = Thread.currentThread().getName();

System.out.println(name + ":任務(wù)A開始執(zhí)行");

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

futureDateA.setData(name + ":任務(wù)A執(zhí)行結(jié)果");

System.out.println(name + ":任務(wù)A執(zhí)行結(jié)束");

}

}, "線程A");

Thread b = new Thread(new Runnable() {

@Override

public void run() {

String name = Thread.currentThread().getName();

System.out.println(name + ":任務(wù)B開始執(zhí)行");

try {

Thread.sleep(3000);

} catch (InterruptedException e) {

e.printStackTrace();

}

futureDateB.setData(name + ":任務(wù)B執(zhí)行結(jié)果");

System.out.println(name + ":任務(wù)B執(zhí)行結(jié)束");

}

}, "線程B");

Date before = new Date();

a.start();

b.start();

Date after = new Date();

System.out.println(name + ":a,b阻塞主線程時(shí)間:"

+ (after.getTime() - before.getTime()));

// 假設(shè)其他業(yè)務(wù)執(zhí)行兩秒鐘

Thread.sleep(2000);

before = new Date();

String dataA = futureDateA.getData();

after = new Date();

System.out.println(name + ":獲取A線程結(jié)果時(shí)間:"

+ (after.getTime() - before.getTime()));

before = new Date();

String dataB = futureDateB.getData();

after = new Date();

System.out.println(name + ":獲取線程結(jié)果時(shí)間:"

+ (after.getTime() - before.getTime()));

System.out.println(name + ":A線程結(jié)果：" + dataA);

System.out.println(name + ":B線程結(jié)果：" + dataB);

Date endOn = new Date();

/*System.out.println(name + "整個(gè)業(yè)務(wù)耗時(shí)"

+ (endOn.getTime() - startOn.getTime()));*/

return endOn.getTime() - startOn.getTime();

}

public long notUseFuture() throws InterruptedException {

Date startOn = new Date();

// 任務(wù)A

String name = Thread.currentThread().getName();

System.out.println(name + ":任務(wù)A開始執(zhí)行");

Thread.sleep(1000);

System.out.println(name + ":任務(wù)A執(zhí)行結(jié)束");

// 任務(wù)B

System.out.println(name + ":任務(wù)B開始執(zhí)行");

Thread.sleep(3000);

System.out.println(name + ":任務(wù)B執(zhí)行結(jié)束");

// 主線程其他操作

Thread.sleep(2000);

Date endOn = new Date();

return endOn.getTime() - startOn.getTime();

}

}

總結(jié)

以上是生活随笔為你收集整理的java多线程 future_Java多线程Future模式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。