> Java > java지도 시간 > 본문

Java의 미래 패턴

巴扎黑
풀어 주다: 2017-06-26 11:45:16
원래의
1361명이 탐색했습니다.

ㅋㅋㅋ .

FutureTask는 위에서 언급한 submit 메소드에 등장했는데, 이를 멈추고 Java

Future 모드로 방향을 바꿔야 했습니다. Future는 동시 프로그래밍의 디자인 패턴으로, 스레드 AB 스레드의 결과를 기다려야 합니다. 먼저 미래 Future를 얻은 다음 B

결과가 나온 후에 실제 결과를 얻을 수 있습니다.

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(callable);    //主线程需要callable线程的结果,先拿到一个未来的FutureSystem.out.println(future.get());    //有了结果后再根据get方法取真实的结果,当然如果此时callable线程如果没有执行完get方法会阻塞执行完,如果执行完则直接返回结果或抛出异常
로그인 후 복사
즉, Future는 비동기 계산의 결과를 나타냅니다.  위는 Future 모드의 실행 원리를 나타냅니다. 온라인 예제에 따르면 Future 모드를 직접 구현할 수 있습니다.
1 package com.future;2 3 /**4  * 数据结果5  * Created by yulinfeng on 6/18/17.6  */7 public interface Data {8     String getResult() throws InterruptedException;9 }
로그인 후 복사
 1 package com.future; 2  3 /** 4  * 结果的真实计算过程 5  * Created by yulinfeng on 6/18/17. 6  */ 7 public class RealData implements Data { 8     protected String data; 9 10     public RealData(String data) {11         try {12             System.out.println("正在计算结果");13             Thread.sleep(3000);     //模拟计算14         } catch (InterruptedException e) {15             e.printStackTrace();16         }17         this.data = data + “ world”;18     }19 20     public String getResult() throws InterruptedException {21         return data;22     }23 }
로그인 후 복사
 1 package com.future; 2  3 /** 4  * 真实结果RealData的代理 5  * Created by yulinfeng on 6/18/17. 6  */ 7 public class FutureData implements Data { 8     RealData realData = null;   //对RealData的封装,代理了RealData 9     boolean isReady = false;    //真实结果是否已经准备好10 11     public synchronized void setResultData(RealData realData) {12         if (isReady) {13             return;14         }15         this.realData = realData;16         isReady = true;17         notifyAll();    //realData已经被注入到了futureData中,通知getResult方法18     }19 20     public synchronized String getResult() throws InterruptedException {21         if (!isReady) {22             wait();     //数据还未计算好,阻塞等待23         }24         return realData.getResult();25     }26 }
로그인 후 복사

 1 package com.future; 2  3 /** 4  * Client主要完成的功能包括:1. 返回一个FutureData;2.开启一个线程用于构造RealData 5  * Created by yulinfeng on 6/18/17. 6  */ 7 public class Client { 8  9     public Data request(final String string) {10         final FutureData futureData = new FutureData();11 12         /*计算过程比较慢,单独放到一个线程中去*/13         new Thread(new Runnable() {14 15             public void run() {16                 RealData realData = new RealData(string);17                 futureData.setResultData(realData);18             }19         }).start();20 21         return futureData;  //先返回一个“假”的futureData22     }23 }
로그인 후 복사

 1 /** 2  * 负责调用Client发起请求,并使用返回的数据。 3  * Created by yulinfeng on 6/18/17. 4  */ 5 public class Main { 6     public static void main(String[] args) throws InterruptedException { 7         Client client = new Client(); 8         System.out.println("准备计算结果"); 9         Data data = client.request("hello");    //立即返回一个“假”的futureData,可以不用阻塞的等待数据返回,转而执行其它任务10         System.out.println("执行其它任务");11         Thread.sleep(3000);     //模拟执行其它任务12         System.out.println("数据的计算结果为:" + data.getResult());13     }14 }
로그인 후 복사

위 프로그램의

Future

패턴 구현을 주의 깊게 읽어보면 어렵지 않게 알 수 있습니다. 패턴은 비동기 요청과 프록시 패턴이 결합됩니다. 물론 Future 모드는

JDK
에서 구현되었습니다.
RealData
클래스 수정:

 1 package com.future; 2  3 import java.util.concurrent.Callable; 4  5 /** 6  * 结果的真实计算过程 7  * Created by yulinfeng on 6/18/17. 8  */ 9 public class RealData2 implements Callable<String> {10     protected String data;11 12     public RealData2(String data) {13         this.data = data;14     }15     public String call() throws Exception {16         try {17             System.out.println("正在计算结果");18             Thread.sleep(2000);     //模拟计算结果19         } catch (InterruptedException e) {20             e.printStackTrace();21         }22         this.data = data + " world";23         return data;24     }25 }
로그인 후 복사
MainTest 클래스 수정:
 1 package com.future; 2  3 import java.util.concurrent.ExecutionException; 4 import java.util.concurrent.ExecutorService; 5 import java.util.concurrent.Executors; 6 import java.util.concurrent.Future; 7  8 /** 9  * 负责调用Executor的submit,并使用返回的数据。10  * Created by yulinfeng on 6/18/17.11  */12 public class Main2 {13 14     public static void main(String[] args) throws InterruptedException, ExecutionException {15         ExecutorService client = Executors.newSingleThreadExecutor();   //类似Client16         System.out.println("准备计算结果");17         Future<String> data = client.submit(new RealData2("hello"));    //类似Client.request18         System.out.println("执行其它任务");19         Thread.sleep(3000);20         System.out.println("数据的计算结果为:" + data.get());21     }22 }
로그인 후 복사

  现在回到上文还未解决完的AbstractExecutorService#submit方法。

  类比上面的Client#request方法,在Client#request中先创建一个FutureData实例,而在AbstractExecutorService#submit中则是创建一个FutureTask实例,接着Client#request新创建一个线程用于异步执行任务,并直接返回FutureData,而在AbstractExecutorService#submit中同样也将任务交给了execute方法,并直接返回FutureTask。当然JDKFuture模式的实现更为复杂。

  在《12.ThreadPoolExecutor线程池原理及其execute方法》中我们讲解了execute方法,在ThreadPoolExecutor$Worker#runWorker方法第1145行中是对task任务的调用:

//ThreadPoolExecutor$Worker#runWorkertask.run();
로그인 후 복사

   submit调用execute以执行run方法,实际执行的是FutureTask中的run方法。在FutureTask#run中,可以看到对任务Callable类型的task异步的执行,以及结果的保存。

위 내용은 Java의 미래 패턴의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿