架构师训练营第七周作业

@Slf4jpublic class TestTool {
    public static void main(String[] args) throws InterruptedException {        test("https://www.baidu.com/", 100, 10);    }
    public static void test(String url, int requestTotalCount, int concurrency) throws InterruptedException {        ThreadPoolExecutor executor = new ThreadPoolExecutor(10, 10000, 5, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100000));        executor.prestartAllCoreThreads();        CountDownLatch countDownLatch = new CountDownLatch(requestTotalCount);        Map<Integer, Future<Long>> futureMap = IntStream.range(0, requestTotalCount)                .boxed()                .collect(Collectors.toMap(Function.identity(), i -> executor.submit(new RequestThread(url, countDownLatch))));        countDownLatch.await();        List<Long> responseTimeList = futureMap.entrySet().stream()                .mapToLong(entryset -> {                    try {                        return entryset.getValue().get();                    } catch (Exception e) {                        log.error(e.getMessage(), e);                    }                    return 0L;                }).boxed().collect(Collectors.toList());        OptionalDouble optionalDouble = responseTimeList.stream().mapToLong(i -> i).average();        log.error("----------avg response time:{}ms", optionalDouble.orElse(0.));        List<Long> sortResponseTimeList = responseTimeList.stream().sorted().collect(Collectors.toList());        int index = BigDecimal.valueOf(0.95).multiply(new BigDecimal(requestTotalCount)).intValue();        log.error("----------95% response time:{}ms", sortResponseTimeList.get(index));        log.error(JSONUtils.toJSON(sortResponseTimeList));        executor.shutdown();        log.error("-------main thread finished");    }
    private static class RequestThread implements Callable<Long> {        private String url;        private CountDownLatch countDownLatch;
        public RequestThread(String url, CountDownLatch countDownLatch) {            this.url = url;            this.countDownLatch = countDownLatch;        }
        @Override        public Long call() {            long startTime = System.currentTimeMillis();            try {                HttpUtil.get(url);            } catch (Exception e) {                log.error(e.getMessage(), e);            } finally {                countDownLatch.countDown();            }            return System.currentTimeMillis() - startTime;        }    }}

----------avg response time:148.05ms----------95% response time:1395ms