阻塞代码在一个线程中执行

Question

我创建了 WorkerExecutor 执行器并尝试执行 2 段长期代码。我的代码：

public class BVerticle extends AbstractVerticle {
    @Override
    public void start() throws Exception {
        WorkerExecutor executor = vertx.createSharedWorkerExecutor("worker", 10, 10000);
        executor.executeBlocking(future -> {
            out.printf("start 1, %s \n", Thread.currentThread().getName());
            try {
                Thread.sleep(5_000L);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            future.complete();
        }, result -> {
            out.printf("finish 2, %s \n", Thread.currentThread().getName());
        });
        executor.executeBlocking(future -> {
            out.printf("start 2, %s \n", Thread.currentThread().getName());
            try {
                Thread.sleep(5_000L);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            future.complete();
        }, result -> {
            out.printf("finish 2, %s \n", Thread.currentThread().getName());
        });
    }
}

执行后输出：

start 1, worker-0
start 2, worker-0
finish 2, vert.x-eventloop-thread-1
finish 2, vert.x-eventloop-thread-1

为什么阻塞代码只在一个线程中执行？

Answer 1

我在文档中找到了答案，我需要执行：

executeBlocking(Handler<Future<T>> blockingCodeHandler, boolean ordered, Handler<AsyncResult<T>> resultHandler)

使用 ordered = false，否则我的代码将串行运行，而不是在同一上下文中并行运行

阻塞代码在一个线程中执行

Blocking code is executed in the one thread

java

vert.x