每当我使用以下命令启动定序器时：
Sequencer sequencer = MidiSystem.getSequencer();
sequencer.open();
// code....
sequencer.start();
sequencer.close(); //it closes the sequencer immediately with no sound being played
如何确保sequencer已经播放完声音，然后调用close()方法？我不想使用时间延迟。
浏览 0提问于2018-03-06得票数 0
我读过和，我知道这个概念是
你可以把期货和承诺看作是管道的两个不同的侧面。在承诺方面，数据被推入，而在未来方面，数据可以被提取出来。
现在，我想知道如何使用Java 8的CompletableFuture来做同样的事情。
示例代码：
Promise<String> promise = new Promise.DefaultPromise<>();
listOfString.stream().forEach(oneString -> {
promise.trySuccess(oneString);
});
//..... some other com
浏览 2提问于2017-06-13得票数 2
回答已采纳
据我所知，获得的唯一方法是使用ExecutorService，例如通过Executors.newFixedThreadPool(10)获得的(顺便说一句，您如何使用多少个线程？)有什么经验法则吗？)
所以我不明白的是，我是否应该使用：
ExecutorService executorService = Executors.newFixedThreadPool(n);
然后保存它(例如在顶级IoC中)，并在需要新的Future时调用executorService
我是否可以使用默认的Java内置ExecutorService，从而避免ExecutorService初始化和维护的麻烦？
浏览 5提问于2016-05-20得票数 9
我有机会在Java8中设计一些与异步数据存储相关的API。我希望我的方法返回承诺，即CompletableFuture而不是Future。然而，我还没有见过很多这样的API(但这可能是因为它们还没有在java8上)。
考虑到CompletableFuture与简单的Future相比最终带来了这么多，这个决定是否明智？
浏览 1提问于2014-12-11得票数 1
回答已采纳
这个问题的目的是找到ThreadPool配置的正确选择，将其与单例模式(即服务层)中的Java7s CompletableFuture一起使用，以进行x次并发调用。
简单介绍一下java应用程序结构。
基于Java的WebServices，使用Spring的依赖注入、C3P0连接池，使用泽西提供的一系列API
由于状态、启用事务的prototype/request服务层、Hibernate DAO层(我们已经大量使用了标准)，控制器都是的作用域。
有超过100 (100)个api，然后有这1个只读聚合器api，它结合了其他10个只读api的结果。api具有以下结构
@Contr
浏览 2提问于2017-12-02得票数 0
我正在编写集成测试用例，我被困在无法模拟CompletableFuture.join()的地方。
首先，我将进行异步调用，并将所有响应添加到列表中。
@Async("AsyncTaskExecutor")
public <T> CompletableFuture<ResponseEntity<T>> callCarrierPost(
ServiceConfig serviceConfig, Class<T> responseType, ExecutionContext executionContex
浏览 6提问于2022-08-22得票数 0
我使用Java8 steam和CompletableFuture请求方法来获取返回值，是什么导致了这个异常？我现在不能重现这个异常：
异常堆栈
java.lang.IllegalStateException
at java.util.stream.Nodes$FixedNodeBuilder.end(Nodes.java:1232)
at java.util.stream.Sink$ChainedReference.end(Sink.java:258)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:
浏览 1提问于2021-11-08得票数 1
1回答
我有几个线程类，它们使用不同的比较方法。我已经将它们实现为扩展抽象类。例如,
public abstract class MatcherThread implements Runnable{
List<String> clusters;
int output;
public MatcherThread(List<String> clusters){
this.clusters = clusters;
}
public void run()
{
for(List<String>
浏览 0提问于2018-09-20得票数 2
回答已采纳
1回答
用java实现多线程的正确方法？
、、、、
在数组中搜索数字的正常版本：
boolean search(int x, int[] arr) {
for (int i : arr) {
if (i == x) {
return true;
}
}
return false;
}
我的多线程方式：
boolean searchAsync(int x, int[] arr, int lo, int hi) {
if (lo == hi) {
浏览 4提问于2021-12-21得票数 1
我使用的是Play！2.5 (Java)和Akka。这是我的问题:我试图调用一个外部服务使用WSClient，并希望它是背后的阿克卡断路器。下面显示的代码似乎不像预期的那样工作。
当无法访问外部服务时，我希望断路器打开，但它不能打开。我猜问题是在包装一个在akaa.dispatch.Future.future中返回一个akaa.dispatch.Future.future的java8lambda表达式时。
我的代码看上去正确吗？如果出了什么问题，我该怎么解决呢？
@Inject
public ServiceActor(WSClient ws) {
this.w
浏览 0提问于2016-10-30得票数 0
1回答
背景
几天前，AWS的2.1版本正式发布。主要的卖点之一是它如何处理异步调用与上一版本的SDK。
我决定使用Scala和新的SDK进行一些实验，并尝试想出一种惯用的方法来处理SDK返回的未来。
问题
有什么办法可以让我做得更好，更成功，用更少的样板代码？
目标
使用Scala处理，并能够以惯用的方式处理成功和失败。
实验
创建异步SNS客户端并异步提交消息500：
实验1-使用SDK返回的CompletableFuture
(0 until 500).map { i =>
val future = client.publish(PublishRequest.builder()
浏览 1提问于2018-11-26得票数 1
回答已采纳
2回答
我使用Spring boot创建了Webservice，其中有一个rest控制器，它通过基于供应商的JDBC驱动程序访问数据库并获取记录。在这个过程中，检索到的记录数量超过80K条记录。由于这一点，当我们作为客户端访问rest端点时，我们会收到超时错误。 我已经尝试使用下面的tutorial.But设置异步调用。不幸的是，rest调用仍然超时。 https://howtodoinjava.com/spring-boot2/enableasync-async-controller/ 控制器 @RequestMapping(value = "/v1/lr/fullposition
浏览 41提问于2019-05-09得票数 0
我必须构建自定义类型的对象，并且在返回和填充对象之前有多次调用。
我必须使用Java 8 Future并行构建对象，这样代码块才会更好。
代码如下所示-
public CustomRequest getCustomRequest(Member member,
Address address,Member member){
CustomRequest customRequest = new CustomRequest();
CompletableFuture.runAsync(() -> {
populateAddress(address, cus
浏览 4提问于2019-08-01得票数 1
回答已采纳
我有一个可完成的未来，它只运行另一个可完成的未来(总是花费大约2秒，超时50 ms)，并等待它以超时1秒完成。
问题是，内部未来的超时从来不起作用，但是get工作了大约2秒，尽管它有50 ms的超时时间，从而导致外部CompletableFuture超时。
sleepFor2000Ms调用Thread.sleep(2000)
private static void oneCompletableFutureInsideAnother() throws InterruptedException, ExecutionException{
long time = System.nanoTime
浏览 14提问于2022-08-23得票数 4
让我们想象一下，我们有n个独立的阻塞IO任务，例如对另一个服务器的rest调用任务。那么所有的答案我们都需要结合起来。每项任务都可以处理超过10秒。
我们可以按顺序处理它，在结束时花费~n*10秒：
Task1Ans task1 = service1.doSomething()；Task2Ans task2 = service2.doSomething()返回结果；
另一种策略是使用CompletableFuture并行处理它，并在所有任务上花费10秒时间：
CompletableFuture task1Cs = CompletableFuture.supplyAsync(()
浏览 14提问于2022-05-05得票数 3
在Java中构建一个完整的未来的最佳方式是什么？我已经在下面实现了我自己的CompletedFuture，但我希望已经存在这样的东西。
public class CompletedFuture<T> implements Future<T> {
private final T result;
public CompletedFuture(final T result) {
this.result = result;
}
@Override
public boolean cancel(final boolean
浏览 0提问于2012-12-14得票数 98
回答已采纳
Q1。我的理解是，如果将来正常或异常地完成，就会调用completableFuture.handle。但是，超时的情况又如何呢？
Q2。哪里可以检查completableFuture的默认超时设置？如何改变它？未来超时后会发生什么？(完成还是异常?)
Q3。只要将来“完成”(完成或超时或其他任何最后阶段)，我就需要执行doSomething()。有没有一个方法可以保证在将来“完成”后被调用？我应该把doSomething()放在哪里？
对可完成的未来来说是新的。更喜欢Java 8的答案。谢谢你的帮助。
浏览 3提问于2018-08-09得票数 1
在Oracle站点上阅读了本文之后，我正在尝试实现“一些一对一的选择模式”段落中描述的模式。最后一类模式也包含一对一的模式。但这一次，不是一次执行下游元素，而是完成两个上游元素，当两个上游元素中的一个完成时，执行下游元素。例如，当我们想解析一个域名时，这可能是非常有用的。与仅查询一个域名服务器不同，我们可能会发现查询一组域名服务器的效率更高。我们不期望从不同的服务器得到不同的结果，所以我们不需要比第一个得到更多的答案。所有其他查询都可以安全地取消。
实现一个只有2个CompleatableFuture的场景很简单，但是我不能用3个或更多的CompleatableFuture实现相同的场景。
我
浏览 3提问于2017-04-13得票数 4
回答已采纳
我希望将多个请求并行发送到want服务。结果应该通过success + error收集，然后调用者可以进一步分析。
public Map.Entry<Rsp, Errors> sendApiRequests(List<Req> reqs) {
//will mostly remain null as errors won't occur frequently
List<Rsp> errors = null;
List<CompletableFuture<Rsp>> futures =
浏览 2提问于2018-02-01得票数 2
Android Studio 3.4.2
我有java文件(，目前还不能转换为Kotlin )。
在build.gradle中：
android {
compileOptions {
sourceCompatibility JavaVersion.VERSION_1_8
targetCompatibility JavaVersion.VERSION_1_8
}
compileSdkVersion 29
defaultConfig {
minSdkV
浏览 0提问于2019-07-15得票数 1
我有以下类，它在与启动FutureTask的线程相同的线程上运行FutureTask。
有没有一种方法可以使用CompletableFuture实现这一点？
我这样问是因为我最终想要利用将多个CompletableFuture链接在一起的优势。具有指定它们是在与执行线程相同的线程上运行还是在不同线程上运行的能力。
public class SameThreadFutureTask {
public static void main(String[] args) throws ExecutionException, InterruptedException {
System.ou
浏览 5提问于2021-07-29得票数 1
最近，我正在尝试实现一个电子邮件服务，它同时向每个用户发送电子邮件。我当前的实现当前如下所示：
ExecutorService executor = Executors.newSingleThreadExecutor();
tasks.forEach(executor::execute); // Each task sends an email to an user
executorService.shutdown(); // Reclaim all the resources
经过一些研究，我找到了一种新的方法，使用Java8 CompletableFuture.runAsync(...)方
浏览 0提问于2018-08-22得票数 6
回答已采纳
给予：
public class Test
{
public static void main(String[] args)
{
int nThreads = 1;
Executor e = Executors.newFixedThreadPool(nThreads);
CompletableFuture.runAsync(() ->
{
System.out.println("Task 1. Thread: " + Thread.currentThread().ge
浏览 1提问于2014-10-26得票数 11
回答已采纳
2回答
我正在制作一个新闻更新应用程序。为此，它需要能够在给定的时间内获得更新。在这个过程中，我创建了一个计时器来在给定的时间内运行可调用的插件。这里我使用了一个FixedThreadPool(执行器)。为此，我想知道未来何时完成了它的工作，以便我可以调用updateHeadlines方法。但是当我使用finished.get()时，它会阻塞gui。有什么方法可以知道什么时候工作已经完成，我可以在那之后更新GUI。
for (Callable curplugin : plugin) {
new Timer(((NewsPlugin) curplugin).getUpdate
浏览 4提问于2017-10-25得票数 2
回答已采纳
在我的应用程序中，我们将数据保存到事务块中的表和ES中。
表A(内部使用OneToMany)
表B
弹性搜索
如上所述，3是独立的操作，我想使用CompletableFuture.allOf()，但无法找到正确的示例。
注意：我不能破坏跨国行为，并希望通过异步运行来提高性能。期望布尔值在返回201之前确保操作成功
浏览 3提问于2017-11-29得票数 1
在java-9中，引入了CompletableFuture类中的CompletableFuture：
public CompletableFuture<T> completeOnTimeout(T value, long timeout,
TimeUnit unit) {
if (unit == null)
throw new NullPointerException();
if (result == null)
whenComplete(ne
浏览 1提问于2018-03-27得票数 15
我正在使用下面的示例代码，其中CompletableFuture链接了多次，我想知道为什么当抛出异常时，链接代码不会在堆栈跟踪中多次出现。
package com.yannick;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException;
public class AsyncExceptionNestingTestMain {
public static void main(String[] args) throws Exception {
浏览 16提问于2019-11-15得票数 1
回答已采纳
2回答
当将两个独立的CompletableFuture与返回第三个BiFunction的BiFunction组合时，我试图避免嵌套one。目前，使用thenCombine()并不会削减它：
// What I have
public CompletableFuture<CompletableFuture<C>> doStuff() {
CompletableFuture<A> aFuture = makeSomeA();
CompletableFuture<B> bFuture = makeSomeB();
Completabl
浏览 4提问于2017-02-13得票数 9
回答已采纳
我刚刚开始探索Java 8的一些并发特性。有一件事让我有点困惑，那就是这两个静态方法：
CompletableFuture<Void> runAsync(Runnable runnable)
CompletableFuture<U> supplyAsync(Supplier<U> supplier)
有人知道他们为什么选择使用接口供应商吗？使用Callable不是更自然吗?Callable类似于Runnable返回值。这是因为供应商不会抛出无法处理的异常吗？
浏览 0提问于2016-03-28得票数 24
回答已采纳
3回答
我正在处理Java8 8的流和CompletableFuture。我以前存在的代码有一个类，它接受一个URL并下载它：
public class FileDownloader implements Runnable {
private URL target;
public FileDownloader(String target) {
this.target = new URL(target);
}
public void run() { /* do it */ }
}
现在，这个类从发出List<String>的另一个部分获取它的信
浏览 4提问于2015-05-20得票数 5
回答已采纳
我在使用CompletableFuture时遇到了以下用例： public void someFunction () {
CompletableFuture.runAsync(() -> computations())
.exceptionally((err) -> {
log.info(err + "");
return null;
});
}
public void computations() {
list.stream.forEach(() -> otherFunction());
}
public v
浏览 211提问于2021-11-04得票数 0
回答已采纳
我期望从下面的代码，由于超时，完全期货将停止处理。但我可以看出取消没有任何效果。
public class CompletableFutureTest {
public static void main(final String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(10);
CompletableFuture completableFuture;
CompletableFuture completableFuture2;
co
浏览 10提问于2022-05-05得票数 0
我对这段代码有疑问：
@Async
public CompletableFuture<String> doFoo() {
CompletableFuture<String> fooFuture = new CompletableFuture<>();
try {
String fooResult = longOp();
fooFuture.complete(fooResult);
} catch (Exception e) {
fooFuture.completeException
浏览 1提问于2017-11-17得票数 27
回答已采纳
我读到过CompletableFuture有能力将多个期货与runAfterBoth合并，但如果我想合并超过两个呢？
CompletableFuture<Boolean> a = new CompletableFuture<>();
CompletableFuture<Boolean> b = new CompletableFuture<>();
CompletableFuture<Boolean> c = new CompletableFuture<>();
List<CompletableFuture<B
浏览 1提问于2016-12-10得票数 0
回答已采纳
我想要一些关于使用CompletableFuture的好方法的建议。
如果我有一个整数列表，对于每个整数，我想执行3个操作，这需要一些时间。例如，乘法、除法和减法。
对于结果，它应该是map，其中key是整数，value是具有三个操作结果的列表。
场景1:如果我想在处理完一个整数后将结果写到map中，那么下面是不是一个很好的方法呢？
for (int x : nums) {
CompletableFuture<Integer> multiply = CompletableFuture.supplyAsync(() -> multiply(x));
Completabl
浏览 3提问于2020-03-04得票数 0
我有以下方法：
@EnableAsync
@Service
Class MyService{
private String processRequest() {
log.info("Start processing request");
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
log.info(&#
浏览 1提问于2020-11-06得票数 5
回答已采纳
在不同版本的java下，我从相同的代码片段中得到不同的输出。我无法在打开的jdk bug跟踪器上找到相关的票证。
CompletableFuture<String> completableFuture = new CompletableFuture<>();
completableFuture.complete("xxx");
completableFuture.thenCompose(str -> {
CompletableFuture<String> completableFuture1 = new Completable
浏览 4提问于2016-08-08得票数 2
回答已采纳
我想异步调用外部api 3次，然后等待它们返回。我的代码如下所示：
public ResponseClass callApi(xxx) {
// ... other code
ResponseClass response = restTemplate.postForEntity(
requestUrl,
httpEntity,
ResponseClass.class
).getBody();
return response;
}
public void otherMethod() {
Comple
浏览 10提问于2021-08-15得票数 1
我希望等待多个事件，并决定尝试用CompletableFuture实现这一点。
CompletableFuture a1 = new CompletableFuture();
CompletableFuture a2 = new CompletableFuture();
CompletableFuture a3 = new CompletableFuture();
CompletableFuture b = new CompletableFuture();
CompletableFuture subFuturesA= CompletableFuture.allOf(a1, a2, a3);
C
浏览 13提问于2022-07-14得票数 1
回答已采纳
1回答
private void processEvents(List<Object> events) {
CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(
() -> processEventsAsynchronously(events));
while (!completableFuture.isDone() || completableFuture.isCancelled() || completableFu
浏览 15提问于2021-12-04得票数 1
例如，我有这样的方法：
public CompletableFuture<Page> getPage(int i) {
...
}
public CompletableFuture<Document> getDocument(int i) {
...
}
public CompletableFuture<Void> parseLinks(Document doc) {
...
}
我的流量：
List<CompletableFuture> list = IntStream
.range(0, 10)
.ma
浏览 2提问于2016-09-30得票数 6
在CompletableFuture.supplyAsync()的生产环境中发现了一个问题，我们有一个批处理方法，如下所示：
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
public class CompletableFutureProblem {
public voi
浏览 5提问于2020-11-21得票数 3
回答已采纳
给定存储库类，它返回一个单独的：
Single<SomeObject> find()
和返回浮点数的CompletableFuture：
CompletableFuture<Long> completableFuture
我想首先调用存储库方法，根据结果，我需要调用completableFuture。这是我的代码：
repository.find()
.flatMap(s -> {
CompletableFuture<Long> completableFuture = serviceReturningCo
浏览 1提问于2019-12-02得票数 0
回答已采纳
您好:我想知道如何编写异步表迭代器。假设输入表由许多行组成，当接收到该表时，它是序列化格式的。当接收到表时，将调用迭代器逐行检索。
它以以下方式执行读取和反序列化: 1)它首先读取与行大小有关的整数，然后反序列化它。2)然后读取并反序列化该行的内容，其中，a。timestamp首先通过调用in.readint()准备好，b。然后读取并反序列化该行的每个键，c。然后读取并反序列化关于非键列的位图字符串。d.然后调用in.readint()读取并反序列化表示非键列数量的整数，然后读取并反序列化每个非键列。3)最后，它读取并反序列化文件结束标记，该标记指示是否到达文件的结尾。
最后，它返回反序列化的
浏览 0提问于2018-07-04得票数 5
3回答
嵌套期货未执行
、、
我遇到了一个奇怪的情况。我正在摆弄CompletableFuture，当运行以下代码时，我得到了意想不到的结果：
public static void main(String[] args) {
CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<Object>>>>>> completableFutureCompletableFuture =
浏览 4提问于2017-02-20得票数 3
回答已采纳
1回答
如何将复杂的未来和流一起使用
、、、、
我想同时使用CompletableFuture和Stream。类似于将CompletableFuture<Stream<String>>转换为CompletableFuture<Stream<Team>>。
我做过类似的事情，从CompletableFuture<String>到CompletableFuture<Integer>。
CompletableFuture<Stream<String>> getMostPopularTeamNames(int maxResults) {
Comp
浏览 0提问于2019-07-01得票数 3
回答已采纳
我有一个返回CompletableFuture<T>的doTransmit方法。我想在一个循环中调用doTransmit，收集所有的CompletableFuture<T>并将其转换为一个CompletableFuture<List<T>>，当所有收集的List<T>都已被解析时，它将使用CompletableFuture<T>进行解析。
CompletableFuture<DeliveryResponse> doTransmit(Notification notification, Receiver rece
浏览 2提问于2019-01-25得票数 1
我想知道使用zip使用CompletableFuture的官方机制是什么。到目前为止，我只使用thenCombine操作符。这是我的例子。
@Test
public void zip() throws InterruptedException {
CompletableFuture<Either<Integer, String>> completableFuture = CompletableFuture.supplyAsync(this::getValue);
CompletableFuture<Either<Integer, String
浏览 0提问于2017-10-17得票数 1
由于以下错误，我在使用getPrice()方法返回汽车价格值时遇到了问题：
no instance(s) of type variable(s) U exist so that CompletableFuture<U> conforms to Double inference variable U has incompatible bounds: equality constraints: Double lower bounds: CompletableFuture<U81345>
我希望getPrice返回CompletableFuture<Double>
浏览 11提问于2022-09-20得票数 3
回答已采纳
1回答
我正在测试CompletableFuture是如何工作的。我对如何并行执行任务感兴趣：
try {
CompletableFuture one = CompletableFuture.runAsync(() -> {
throw new RuntimeException("error");
});
CompletableFuture two = CompletableFuture.runAsync(() -> System.out.println("2"));
浏览 0提问于2019-03-23得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
