```java

@Test
public void demo() {
QueryTask var0 = new QueryTask(900);
QueryTask var1 = new QueryTask(2100);
QueryTask var2 = new QueryTask(2000);
QueryTask var3 = new QueryTask(2000);

Demo<QueryTask, Integer> test = new Demo<>(1000, List.of(var0, var1, var2, var3));
long l = System.currentTimeMillis();
Collection<Integer> d = test.execute();
System.out.println(System.currentTimeMillis() - l);
assert d.size() > 0;
for (Integer integer : d) {
assert integer <= 1000;
}
}
static class Demo<T extends Supplier<E>, E> {
private static final ExecutorService ES = Executors.newFixedThreadPool(10);
private final int timeout;
private final Collection<T> tasks;
Demo(int timeout, Collection<T> tasks) {
this.timeout = timeout;
this.tasks = tasks;
}
public List<E> execute() {
List<CompletableFuture<E>> collect = tasks.stream().map(x -> CompletableFuture.supplyAsync(x, ES)
.completeOnTimeout(null, timeout, TimeUnit.MILLISECONDS))
.collect(Collectors.toUnmodifiableList());

CompletableFuture<List<E>> listCompletableFuture = CompletableFuture.allOf(collect.toArray(new CompletableFuture[collect.size()]))
.thenApply(v -> collect.stream().map(CompletableFuture::join)
.filter(Objects::nonNull)
.collect(Collectors.toList()));
return listCompletableFuture.join();
}
}
static class QueryTask implements Supplier<Integer> {
private final int time;
QueryTask(int time) {
this.time = time;
}
@Override
public Integer get() {
try {
//query
Thread.sleep(time);
} catch (InterruptedException e) {
e.printStackTrace();
}
return time;
}
}

```

CompletableFuture 有个 completeOnTimeout 超时的时候可以设置默认值给个 null
最后过滤掉为 null 的

删掉 iml 和.idea 重新检索一次

还是近视最容易有 最近也在注意了

我们这边是打包把第三方的 jar 和源码分开
云盘上面先把第三方的 jar 按照集群应用放上去
启动参数 classpath 指定多一个对应的路径就好了 除非有第三方依赖更改才要更新

@liu99 nginx Support 试试这个插件

nested 的原因吧

6s 用了 5 年 电池容量只有 58%..

@sagaxu 只用 jdk proxy 就要接口 没啥毛病

@sunbreak zen3 单核基本都在 155x-168x 好吧 R23 有差距但对笔记本来说相当可以

现在不建议上 3090 各种 boom 的消息

看错了 无视..

@RequestBody(required = false)

资瓷一波 用快 2 年了

第一个可以用配置解决 第二个拦截器里写代码 HandlerMethod 可以知道是不是 GetMapping 或者 PostMapping 就行了 如果是 RequestMapping 就获取下 method 里面的值判断下

@wysnylc 这个 api 的入参不是队列容量吧

@sagaxu 一般的条件 IDEA 插件自动生成 只有很特殊的才要写

根据自己分发的 clientId 来区分,在 api 网关转发

用这个都要加个 exceptionally(tx -> {log...})
不然你找不出问题