zhady009 最近的时间轴更新
zhady009
ONLINE

zhady009

V2EX 第 262575 号会员,加入于 2017-10-26 09:47:54 +08:00
今日活跃度排名 5874
关于消费者主动拉取任务队列中的问题
Java  •  zhady009  •  247 天前  •  最后回复来自 ChovyChu
10
如果把几个有关系的表创建成一个 document 会面临什么问题?
Elasticsearch  •  zhady009  •  2020-03-11 15:21:03 PM  •  最后回复来自 kanezeng
3
dcpmm 上机记录
硬件  •  zhady009  •  2019-12-15 20:38:26 PM
深圳电信宽带流量过大被直接停机什么情况
宽带症候群  •  zhady009  •  2019-12-10 15:30:24 PM  •  最后回复来自 ZeroKong
56
闲鱼卖东西 买家收到后说有损坏怎么解决?
问与答  •  zhady009  •  2019-10-28 17:40:13 PM  •  最后回复来自 yanwen
15
mysql 日期区间查找 有什么方案可以快速地查找出缺失的日期
Java  •  zhady009  •  2019-09-15 11:19:43 AM  •  最后回复来自 rqrq
4
mybatis 中如何处理插入语句中的美元符号 等特殊字符?
Java  •  zhady009  •  2019-05-22 10:41:02 AM  •  最后回复来自 zhady009
11
有意想入 mbp 请教几个问题
MacBook Pro  •  zhady009  •  2019-04-15 23:07:13 PM  •  最后回复来自 wang2018
22
zhady009 最近回复了
2 天前
回复了 zhangslob669 创建的主题 Java 关于 Java 线程池并发查询的问题
```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;
}
}

```
2 天前
回复了 zhangslob669 创建的主题 Java 关于 Java 线程池并发查询的问题
CompletableFuture 有个 completeOnTimeout 超时的时候可以设置默认值给个 null
最后过滤掉为 null 的
删掉 iml 和.idea 重新检索一次
34 天前
回复了 kerrspace 创建的主题 程序员 码农有哪些职业病和如何预防
还是近视最容易有 最近也在注意了
58 天前
回复了 woyao396 创建的主题 Java 关于 Java 中 maven 多模块项目的疑问
我们这边是打包把第三方的 jar 和源码分开
云盘上面先把第三方的 jar 按照集群应用放上去
启动参数 classpath 指定多一个对应的路径就好了 除非有第三方依赖更改才要更新
@liu99 nginx Support 试试这个插件
nested 的原因吧
116 天前
回复了 teaaa 创建的主题 iPhone 感觉我的 8P 能用到地老天荒了。
6s 用了 5 年 电池容量只有 58%..
关于   ·   帮助文档   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   3171 人在线   最高记录 5497   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 18ms · UTC 10:04 · PVG 18:04 · LAX 03:04 · JFK 06:04
♥ Do have faith in what you're doing.