1.背景
連鎖零售公司旗下有1000家門店根欧，每個(gè)門店的選品過程都是獨(dú)立的怜珍，每個(gè)門店選品執(zhí)行的時(shí)間平均為30秒，單線程串行執(zhí)行所有門店選品需要500分鐘凤粗，因?yàn)闃I(yè)務(wù)上下游給的時(shí)間有限酥泛，需要減少整體的執(zhí)行時(shí)間，執(zhí)行時(shí)間控制在100分鐘內(nèi)嫌拣。
2.思路
并行執(zhí)行柔袁，500/100=5，同時(shí)有五家門店在選品异逐，單臺(tái)機(jī)器并發(fā)執(zhí)行的能力是有限捶索，若超過單臺(tái)機(jī)器的并發(fā)能力可以用定時(shí)任務(wù)分片的方式來擴(kuò)展并發(fā)能力。
3.模擬代碼
3.1.門店選品
/**
* 門店選品
*
public class StoreSelection {
/**
* 門店編碼
*/
private String storeCode;
private final static String TXT = "門店選品開始門店選品開始門店選品開始門店選品開始門店選品開始門店選品開始門店選品開始門店選品開始門店選品開始";
public StoreSelection(String storeCode) {
this.storeCode = storeCode;
}
public String select(){
System.out.println(String.format("%s門店編碼=%s的門店選品開始", LocalDateTime.now(), storeCode));
Base64.Encoder encoder = Base64.getEncoder();
LocalDateTime start = LocalDateTime.now();
LocalDateTime end = start.plusSeconds(30);
//模擬選品過程中有異常
if ("A10".equals(storeCode)) {
throw new RuntimeException(storeCode + "門店選品異常請?zhí)幚?);
}
while (LocalDateTime.now().isBefore(end)) {
//加重CPU負(fù)載
encoder.encode(TXT.getBytes());
//System.out.println(String.format("%s門店編碼=%s的門店選品執(zhí)行中", LocalDateTime.now(), storeCode));
}
System.out.println(String.format("%s門店編碼=%s的門店選品完成", LocalDateTime.now(), storeCode));
return storeCode + "門店選品完成";
}
public static void main( String[] args ) {
new StoreSelection("A1").select();
}
}
3.2.連鎖零售公司旗下所有門店選品
public class GroupSelection{
public static void main( String[] args ) {
List<String> storeCodeList = new LinkedList<>();
for (int i = 0; i < 1000; i++) {
storeCodeList.add("A"+i);
}
System.out.println("門店組選品開始");
ExecutorService executor = Executors.newFixedThreadPool(5);
List<Future<String>> futureList = storeCodeList.stream()
.map(storeCode -> executor.submit(() -> new StoreSelection(storeCode).select()))
.collect(Collectors.toList());
while(!futureList.stream().allMatch(Future::isDone)){
System.out.println("等待所有門店選品執(zhí)行結(jié)束");
}
String re = futureList.stream().map(future -> {
try {
return future.get();
} catch (ExecutionException | InterruptedException e) {
e.printStackTrace();
return e.getMessage();
}
}).collect(Collectors.joining(","));
System.out.println(re);
System.out.println("門店組選品完成");
executor.shutdown();
}
}
