public class TestWorkers extends AbstractVerticle {
    @Override
    public void start() {
        System.out.print("TestWorkers started: ");
        System.out.println(Thread.currentThread().getName());
        WorkerExecutor test = vertx.createSharedWorkerExecutor("test");
        for (int i = 0; i < 10; i++) {
            test.executeBlocking(TestWorkers::runBlocking, false, TestWorkers::handle2);
        }

    }

    private static void runBlocking(Future<Void> asyncResult) {
        System.out.print("Execute blocking works: ");
        System.out.println(Thread.currentThread().getName());
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        Vertx owner = Vertx.currentContext().owner();
        owner.fileSystem().readFile("test.txt", event -> {
            System.out.print("File is read: ");
            System.out.println(Thread.currentThread().getName());
        });
        asyncResult.complete();
    }

    private static void handle2(AsyncResult<Void> asyncResult) {
        System.out.print("Execute blocking result: ");
        System.out.println(Thread.currentThread().getName());
    }
}