java多執行緒之callable+Executor執行緒池例項
阿新 • • 發佈:2018-12-30
package main.java;
import java.sql.Time;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
/**
* 批量任務的限時 invokeAll(tasks) 批量提交不限時任務
*
* invokeAll(tasks, timeout, unit) 批量提交限時任務
*
* InvokeAll方法處理一個任務的容器(collection),並返回一個Future的容器。兩個容器具有相同的結構:
* invokeAll將Future新增到返回的容器中,這樣可以使用任務容器的迭代器,從而呼叫者可以將它表現的Callable與Future 關聯起來。
* 當所有任務都完成時、呼叫執行緒被中斷時或者超過時限時,限時版本的invokeAll都會返回結果。 超過時限後,任務尚未完成的任務都會被取消。
*
*
*
*/
public class InvokeAllThread {
static ExecutorService mExecutor = Executors.newCachedThreadPool();
/**
* 計算價格的任務
*
* @author hadoop
*
*/
private class QuoteTask implements Callable<Integer> {
public final double price;
public final int num;
public QuoteTask(double price, int num) {
this.price = price;
this.num = num;
}
public Integer call() throws Exception {
Random r = new Random();
long time = (r.nextInt(10) + 1) * 1000;
Thread.sleep(time);
Integer d = Integer.valueOf((int) (price * num));
System.out.println("wait:" + time / 1000 + "s,price:" + price + ",num:" + num + ",total:" + d);
return d;
}
}
/**
* 在預定時間內請求獲得旅遊報價資訊
*
* @return
*/
public void getQueueTasks() throws InterruptedException {
int sum = 0 ;
List<QuoteTask> tasks = new ArrayList<QuoteTask>();
// 模擬5個計算旅遊報價的任務
for (int i = 1; i <= 5; i++) {
tasks.add(new QuoteTask(200, i));
}
/**
* 使用invokeAll方法批量提交限時任務任務
*
*/
List<Future<Integer>> futures = mExecutor.invokeAll(tasks);
// 報價合計集合
List<Integer> totalPriceList = new ArrayList<Integer>();
for (Future<Integer> future : futures) {
try {
totalPriceList.add(future.get());
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
for (Integer Integer : totalPriceList) {
sum = sum+Integer;
}
System.out.println("總價:"+sum);
mExecutor.shutdown();
}
public static void main(String[] args) {
try {
InvokeAllThread it = new InvokeAllThread();
it.getQueueTasks();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
import java.sql.Time;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
/**
* 批量任務的限時 invokeAll(tasks) 批量提交不限時任務
*
* invokeAll(tasks, timeout, unit) 批量提交限時任務
*
* InvokeAll方法處理一個任務的容器(collection),並返回一個Future的容器。兩個容器具有相同的結構:
* invokeAll將Future新增到返回的容器中,這樣可以使用任務容器的迭代器,從而呼叫者可以將它表現的Callable與Future 關聯起來。
* 當所有任務都完成時、呼叫執行緒被中斷時或者超過時限時,限時版本的invokeAll都會返回結果。 超過時限後,任務尚未完成的任務都會被取消。
*
*
*
*/
public class InvokeAllThread {
static ExecutorService mExecutor = Executors.newCachedThreadPool();
/**
* 計算價格的任務
*
* @author hadoop
*
*/
private class QuoteTask implements Callable<Integer> {
public final double price;
public final int num;
public QuoteTask(double price, int num) {
this.price = price;
this.num = num;
}
public Integer call() throws Exception {
Random r = new Random();
long time = (r.nextInt(10) + 1) * 1000;
Thread.sleep(time);
Integer d = Integer.valueOf((int) (price * num));
System.out.println("wait:" + time / 1000 + "s,price:" + price + ",num:" + num + ",total:" + d);
return d;
}
}
/**
* 在預定時間內請求獲得旅遊報價資訊
*
* @return
*/
public void getQueueTasks() throws InterruptedException {
int sum = 0 ;
List<QuoteTask> tasks = new ArrayList<QuoteTask>();
// 模擬5個計算旅遊報價的任務
for (int i = 1; i <= 5; i++) {
tasks.add(new QuoteTask(200, i));
}
/**
* 使用invokeAll方法批量提交限時任務任務
*
*/
List<Future<Integer>> futures = mExecutor.invokeAll(tasks);
// 報價合計集合
List<Integer> totalPriceList = new ArrayList<Integer>();
for (Future<Integer> future : futures) {
try {
totalPriceList.add(future.get());
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
for (Integer Integer : totalPriceList) {
sum = sum+Integer;
}
System.out.println("總價:"+sum);
mExecutor.shutdown();
}
public static void main(String[] args) {
try {
InvokeAllThread it = new InvokeAllThread();
it.getQueueTasks();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}