小编T.P*_*.P.的帖子

有没有办法计算完成每个 completableFuture 所需的时间?

在详细讨论问题之前,我想先介绍一下问题的背景。基本上,我的代码看起来像

for(int i = 0; i < n; i++){
    startTime = System.currentTimeMillis();
    result = doSomething();
    endTime = System.currentTimeMillis();
    responseTime.add(endTime - startTime);
    results.add(result);
} 
print(results and responseTime);
Run Code Online (Sandbox Code Playgroud)

现在我想做的是将doSomething()作为 completableFuture 运行并获取上面提到的responseTime。但因为这样做是完全错误的——

for(int i = 0; i < n; i++){
    startTime = System.currentTimeMillis();
    resultCF = CompletableFuture.supplyasync(() -> doSomething());
    endTime = System.currentTimeMillis();
    responseTime.add(endTime - startTime);
    results.add(resultCF); //result is to store the completableFutures
}
CompletableFuture.allOf(results.toArray(new CompletableFuture[results.size()])).join();
print(i.get() for i in results and responseTimes);
Run Code Online (Sandbox Code Playgroud)

因为它会破坏获取每个doSomething()的执行时间的目的。那么,有什么方法可以获得每个 completableFuture 的响应时间吗?另外,我需要在循环末尾包含 completableFutures( resultCF ) 的结果数组列表。

java time asynchronous completable-future

2
推荐指数
1
解决办法
1866
查看次数

Aerospike 特定于 setName 的配置

我是 Aerospike 的新手。我的命名空间有多个集合。我试图在 aerospike dB 命名空间中为不同的集合设置不同的 TTL。

我不想使用分配给命名空间的默认 ttl,而是想为每个集合设置它。

我的配置

namespace test {
        replication-factor 1
        memory-size 1G
        default-ttl 0 
}
Run Code Online (Sandbox Code Playgroud)

我提到了此链接https://docs.aerospike.com/server/operations/configure,其中指出可以设置特定的记录策略。

namespace <name> {       # Define namespace record policies and storage engine
    storage {}           # Configure persistence or lack of persistence
    set {}               # (Optional) Set specific record policies
}
Run Code Online (Sandbox Code Playgroud)

但我不确定应该使用哪个字段来设置每组的 ttl。比如说,我在这个“测试”命名空间中有两个名为 - 的集合order,并且name我希望它们的 ttl 分别为 2 小时和 6 小时。任何帮助,将不胜感激。

提前致谢

caching aerospike

2
推荐指数
1
解决办法
158
查看次数