如何配置Jetty禁用线程池，实现每次请求单独创建和销毁线程

可以实现，你最初的自定义ThreadPool的思路是完全可行的，Jetty本身提供了线程池的抽象扩展点，不需要修改Jetty内核逻辑就能实现每次请求新建、销毁线程的需求。

实现步骤 #

1. 自定义实现Jetty的ThreadPool接口 #

核心逻辑是在execute()方法中每次接收到请求任务直接创建新线程执行，不需要池化复用，完整实现示例如下：

import org.eclipse.jetty.util.thread.ThreadPool;
import org.eclipse.jetty.util.component.LifeCycle;

public class PerRequestThreadPool implements ThreadPool {
    private volatile boolean running = false;

    @Override
    public void execute(Runnable task) {
        // 每次任务进来直接创建并启动新线程，处理完成后线程自动销毁
        new Thread(task).start();
    }

    @Override
    public void join() throws InterruptedException {
        Thread.currentThread().join();
    }

    @Override
    public int getThreads() {
        return Thread.activeCount();
    }

    @Override
    public int getIdleThreads() {
        // 无池化逻辑，不存在空闲线程，直接返回0
        return 0;
    }

    @Override
    public boolean isLowOnThreads() {
        // 不需要做线程数限制的话直接返回false即可
        return false;
    }

    // 以下是Jetty生命周期接口LifeCycle的实现
    @Override
    public void start() {
        running = true;
    }

    @Override
    public void stop() {
        running = false;
    }

    @Override
    public boolean isRunning() {
        return running;
    }

    @Override
    public boolean isStarted() {
        return running;
    }

    @Override
    public boolean isStarting() {
        return false;
    }

    @Override
    public boolean isStopping() {
        return !running;
    }

    @Override
    public boolean isStopped() {
        return !running;
    }

    @Override
    public boolean isFailed() {
        return false;
    }

    @Override
    public void addLifeCycleListener(LifeCycle.Listener listener) {
        // 不需要生命周期监听的话可以空实现
    }

    @Override
    public void removeLifeCycleListener(LifeCycle.Listener listener) {
        // 不需要生命周期监听的话可以空实现
    }
}

2. 将自定义线程池注入Jetty Server #

构造Jetty Server实例时直接传入自定义的线程池对象即可，其余Jetty配置和常规用法完全一致，示例代码：

import org.eclipse.jetty.server.Server;

public class CustomJettyStarter {
    public static void main(String[] args) throws Exception {
        PerRequestThreadPool customThreadPool = new PerRequestThreadPool();
        // 构造Server时直接传入自定义线程池
        Server server = new Server(customThreadPool);
        // 配置服务端口，后续的Handler、Servlet等配置和常规Jetty用法完全一致
        server.setPort(8080);
        // server.setHandler(yourBusinessHandler);
        server.start();
        server.join();
    }
}

补充说明 #

• 如果你采用xml配置的方式启动Jetty，只需要将配置文件中默认的QueuedThreadPool Bean替换为你自定义的线程池类即可，无需修改其他配置。
• 你可以根据业务需求在execute方法中增加自定义逻辑，比如设置线程命名规则、未捕获异常处理器、请求统计逻辑等。
• 该实现完全兼容Jetty的生命周期管理，启动、停止等操作均不会出现兼容性问题。

内容的提问来源于stack exchange，提问作者Dai MIKURUBE