import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;
public class ConcurrentUtils {
public static void stop(ExecutorService executor) {
try {
executor.shutdown();
executor.awaitTermination(
60, TimeUnit.SECONDS);
}
catch (InterruptedException e) {
System.err.println(
"termination interrupted");
}
finally {
if (!executor.isTerminated()) {
System.err.println(
"killing non-finished tasks");
}
executor.shutdownNow();
}
}
public static void sleep(
int seconds) {
try {
TimeUnit.SECONDS.sleep(seconds);
}
catch (InterruptedException e) {
throw new IllegalStateException(e);
}
}
}
转载于:https://www.cnblogs.com/bilaisheng/p/10210899.html
相关资源：JAVA上百实例源码以及开源项目
