Java8-Executors-No.03
2024-09-05 03:50:40
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
public class Executors3 {
public static void main(String[] args) throws InterruptedException, ExecutionException {
test1();
// test2();
// test3();
// test4();
// test5();
}
private static void test5() throws InterruptedException, ExecutionException {
ExecutorService executor = Executors.newWorkStealingPool();
List<Callable<String>> callables = Arrays.asList(
callable("task1", 2),
callable("task2", 1),
callable("task3", 3));
String result = executor.invokeAny(callables);
System.out.println(result);
executor.shutdown();
}
private static Callable<String> callable(String result, long sleepSeconds) {
return () -> {
TimeUnit.SECONDS.sleep(sleepSeconds);
return result;
};
}
private static void test4() throws InterruptedException {
ExecutorService executor = Executors.newWorkStealingPool();
List<Callable<String>> callables = Arrays.asList(
() -> "task1",
() -> "task2",
() -> "task3");
executor.invokeAll(callables)
.stream()
.map(future -> {
try {
return future.get();
}
catch (Exception e) {
throw new IllegalStateException(e);
}
})
.forEach(System.out::println);
executor.shutdown();
}
private static void test3() {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
Runnable task = () -> {
try {
TimeUnit.SECONDS.sleep(2);
System.out.println("Scheduling: " + System.nanoTime());
}
catch (InterruptedException e) {
System.err.println("task interrupted");
}
};
executor.scheduleWithFixedDelay(task, 0, 1, TimeUnit.SECONDS);
}
private static void test2() {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
Runnable task = () -> System.out.println("Scheduling: " + System.nanoTime());
int initialDelay = 0;
int period = 1;
executor.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);
}
private static void test1() throws InterruptedException {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
Runnable task = () -> System.out.println("Scheduling: " + System.nanoTime());
int delay = 3;
ScheduledFuture<?> future = executor.schedule(task, delay, TimeUnit.SECONDS);
TimeUnit.MILLISECONDS.sleep(1337);
long remainingDelay = future.getDelay(TimeUnit.MILLISECONDS);
System.out.printf("Remaining Delay: %sms\n", remainingDelay);
}
}
最新文章
- j2ee部分
- 如何禁止 iPhone Safari video标签视频自动全屏？
- asp.net 微信企业号办公系统-流程设计--流转条件设置（路由）
- Locking
- 近期刷题的c语言总结。
- iOS开发zhiATM机的设计与实现
- 从零开始用 Flask 搭建一个网站（一）
- 算法训练 K好数 数位DP+同余定理
- HDU 1729
- INV_TXN_MANAGER_PUB.PROCESS_TRANSACTIONS
- mysql8.0CTE实现递归查询
- 2016年蓝桥杯省赛A组c++第2题(暴力求解)
- 2019寒假算法基础集训营1 - B 小a与"204"
- 如何在taro的map循环中使用if条件渲染
- 主频3.0 1g内存是什么意思
- Android-BitmapUtil工具类
- 无法正常下载Nuget 包的问题
- android 模仿今日头条ViewPager+TabLayout
- jquery on方法（事件委托）
- LVS,HAPROXY,NGINX各自的优缺点