下面如何做无阻塞IO？

Question

public class App {
    public static void main(String[] args) {
        Undertow server = Undertow.builder().addListener(8080, "localhost")
                .setHandler(new HttpHandler() {

                    public void handleRequest(HttpServerExchange exchange) throws Exception {
                        Thread.sleep(5000);
                        exchange.getResponseHeaders().put(Headers.CONTENT_TYPE, "text/plain");
                        exchange.getResponseSender().send("Hello World");
                    }

                }).build();
        server.start();
    }
}

这一次，第一个选项卡将等待5秒，第二个选项卡将等待10秒

为什么会这样？

Answer 1

HttpHandler在I/O线程中执行。如文件所述：

IO线程执行非阻塞任务，并且永远不应该执行阻塞操作，因为它们负责多个连接，所以当操作阻塞时，其他连接基本上会挂起。每个CPU内核一个IO线程是合理的默认情况。

请求生命周期文档讨论如何将请求分派给辅助线程：

import io.undertow.Undertow;
import io.undertow.server.*;
import io.undertow.util.Headers;

public class Under {
  public static void main(String[] args) {
    Undertow server = Undertow.builder()
        .addListener(8080, "localhost")
        .setHandler(new HttpHandler() {
          public void handleRequest(HttpServerExchange exchange)
              throws Exception {
            if (exchange.isInIoThread()) {
              exchange.dispatch(this);
              return;
            }
            exchange.getResponseHeaders()
                    .put(Headers.CONTENT_TYPE, "text/plain");
            exchange.getResponseSender()
                    .send("Hello World");
          }
        })
        .build();
    server.start();
  }
}