適用的情況
當(dāng)一個(gè)線程向其他線程委托了處理, 然后還想要得到處理結(jié)果時(shí).
實(shí)現(xiàn)的方式
編寫一個(gè)與處理結(jié)果具有相同接口的Future類, 在處理的開始立馬返回該Future對象, 然后等到被委托的線程處理完畢,再將處理結(jié)果設(shè)置到Future對象中.這樣委托處理的線程就可以在自己覺得合適的時(shí)機(jī)去獲取處理結(jié)果, 而不用一直阻塞到結(jié)果完成.
相關(guān)的模式
- 在委托的方法等待處理結(jié)果的部分可以使用Guarded Suspension模式.
- 要想在Thread-Per-Message模式中想要獲取處理結(jié)果的時(shí)候可以使用Future模式.
- 同上, 要想在Worker-Thread模式中獲取處理結(jié)果也可以使用Future模式.
代碼示例:
FutureData是其中的"Future"類的實(shí)現(xiàn), 里面的RealData字段裝載著真實(shí)要返回的數(shù)據(jù), ready則是RealData是否準(zhǔn)備完畢的狀態(tài)flag.
package com.graphic.future;
public interface Data {
String getContent();
}
package com.graphic.future;
public class RealData implements Data {
private final String content;
public RealData(int count, char c) {
System.out.println(" making RealData(" + count + "," + c + ") BEGIN");
char[] buffer = new char[count];
for (int i = 0; i < count; i++) {
buffer[i] = c;
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(" making RealData(" + count + "," + c + ") END");
this.content = new String(buffer);
}
@Override
public String getContent() {
return content;
}
}
package com.graphic.future;
/*
* futureData 是data的取貨單, 如果realData沒有準(zhǔn)備好, 那么就會使用wait()方法阻塞getContent方法.
* 切記, setContent()中一定要調(diào)用 notifyAll(), 否則,調(diào)用futureData()的方法的進(jìn)程會始終阻塞在getContent()方法中!
*
* 個(gè)人理解, workerThread pattern相比于threadPerMessage pattern(最初版本的做法, 不使用java.util.concurrent包)
* 避免了線程啟動(dòng)和銷毀的開銷, 但是這兩種pattern雖然不會阻塞方法的進(jìn)行,但不能獲得處理的返回值.
*
* 但future pattern既不會發(fā)生"阻塞", (這里的意思不是wait()方法, 也就是realData的生成過程中, 調(diào)用getContent()之前, 線程是自由.)
* 其實(shí)這里也可以理解future 實(shí)現(xiàn)了"異步", 它將值生成的過程, 與獲取值的過程 進(jìn)行了分離, 以往值生成的過程, 線程只能傻乎乎在那里等著, 但現(xiàn)在該線程可以去
* 做其他的事情了, 做完其他事情后, 再來利用完成的值, 完成最后的活動(dòng).
* 舉個(gè)例子: 我們想吃泡面的時(shí)候, 先把泡面泡上, 然后泡面泡好之前, 我們可以去看會書, 刷刷微博,知乎, 或者去樓下買杯飲品, 我們可以不傻乎乎的站在泡面前等著它泡好,
* 只要在最后它泡好之后, 記得回來吃了它就行.
*/
public class FutureData implements Data {
private boolean ready = false;
private RealData realData;
public synchronized void setContent(RealData realData) {
if (ready) {
return;
}
this.realData = realData;
ready = true;
notifyAll();
}
@Override
public synchronized String getContent() {
while (!ready) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return realData.getContent();
}
}
package com.graphic.future;
public class Host {
public Data request(final int count, final char c) {
System.out.println(" request(" + count + "," + c + ") BEGIN");
final FutureData futureData = new FutureData();
new Thread() {
@Override
public void run() {
RealData realData = new RealData(count, c);
futureData.setContent(realData);
}
}.start();
return futureData;
}
}
package com.graphic.future;
public class Main {
public static void main(String[] args) {
System.out.println("main BEGIN");
Host host = new Host();
Data data1 = host.request(10, 'A');
Data data2 = host.request(20, 'B');
Data data3 = host.request(20, 'C');
System.out.println("main other job BEGIN");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("data1 = " + data1.getContent());
System.out.println("data2 = " + data2.getContent());
System.out.println("data3 = " + data3.getContent());
System.out.println("main END");
}
}
