架构训练营第七周作业

public static void main(String args[]) throws Exception {        int concurrencyLevel = 10;        int totalCount = 100;
        ExecutorService threadPool = Executors.newFixedThreadPool(concurrencyLevel);        Future<Long>[] futures = new Future[totalCount];        Long[] costs = new Long[totalCount];        for (int i = 0; i < totalCount; i++) {            Future<Long> future = threadPool.submit(new Callable<Long>() {                @Override                public Long call() throws Exception {                    try {                        long start = new Date().getTime();                        URL url = new URL("https://www.baidu.com");                        URLConnection connection = url.openConnection();                        Object content = connection.getContent();                        long end = new Date().getTime();                        return end - start;                    } catch (Exception e) {                        e.printStackTrace();                    }                    return 0l;                }            });            futures[i] = future;        }
        for (int i = 0; i < totalCount; i++) {            costs[i] = futures[i].get();        }        System.out.println("avg cost is: " + getAvgTime(costs) + "ms");
        Collections.sort(Arrays.asList(costs));        System.out.println("95 cost is: " + costs[94] + "ms");    }
    private static double getAvgTime(Long[] costs) {        long total = 0;        for (int i = 0; i < costs.length; i++) {            total += costs[i];        }        return total / costs.length;    }