pool.shutdown();
pool_futures.stream().forEach(it -> { it.cancel(false); });
pool.awaitTermination(XXX, TimeUnit.XXX);
pool.shutdown();
pool_futures.stream().forEach(it -> { it.cancel(false); });
pool.awaitTermination(XXX, TimeUnit.XXX);
© 著作权归作者所有