如何同时调用多个Uni

Question

最近，我正在从事一个项目，其中我有2个同时进行2个异步调用。由于我与Quarkus合作，我最终尝试利用叛变和垂直。x库。然而，我无法让我的代码与Unis一起工作。在下面的代码中，我可以想象两个Uni都将被调用，返回速度最快的Uni将被返回。然而，当组合uni时，似乎只返回列表中的第一个uni，即使第一个uni需要更长的时间。

由于uniFast应该首先完成，所以下面的代码应该在打印时打印出来。如何组合Unis并让更快的Unis先返回？

@Test
    public void testUniJion(){
        var uniSLow = Uni.createFrom().item(() -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "one";
        });

        var uniFast = Uni.createFrom().item(() -> {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "two";
        });

        var resp = Uni.join().first(uniSLow,uniFast).withItem().await().indefinitely();
        System.out.println(resp);

        var resp2 = Uni.combine().any().of(uniSLow,uniFast).await().indefinitely();
        System.out.println(resp2);
    }

注意：这不是我试图实现的实际代码。在我的代码中，我试图从两个不同的数据库中提取数据。然而，一个数据库通常比另一个数据库有更多的延迟。然而，Uni似乎总是在等待较慢的数据库。我只是想更好地理解叛变和Uni，所以我做了这个代码示例。

Answer 1

问题是您没有告诉Mutiny应该在哪个线程上运行每个uni。如果我添加一个系统。根据您的示例：

// Slow and Fast for the different Uni
System.out.println( "Slow - " + Thread.currentThread().getId() + ":" + Thread.currentThread().getName() );

我得到以下输出：

Slow - 1:Test worker
one
Slow - 1:Test worker
Fast - 1:Test worker
one

输出显示所有内容都在同一个线程上运行，因此当我们阻塞第一个线程时，第二个线程也会被阻塞。这就是为什么输出是一个一个。

并行运行uni的一种方法是在订阅时使用不同的执行器：

ExecutorService executorService = Executors.newFixedThreadPool( 5 );
uniSlow = uniSlow.runSubscriptionOn( executorService );
uniFast = uniFast.runSubscriptionOn( executorService );

现在，当我运行测试时，我得到了预期的输出：

Slow - 16:pool-3-thread-1
Fast - 17:pool-3-thread-2
two
Slow - 18:pool-3-thread-3
Fast - 19:pool-3-thread-4
two

请注意，这次Slow和Fast在不同的线程上运行。

穆特尼指南有一节关于emitOn与runSubscriptionOn之间的区别，以及一些关于如何更改发射线程的示例。