当前位置：首页 > Java

java如何监听线程

2026-03-25 16:56:27Java

监听线程的方法

在Java中监听线程状态或活动可以通过多种方式实现，以下是常见的几种方法：

使用Thread类的方法

通过Thread类提供的方法可以监听线程的状态，例如isAlive()、getState()等。

Thread thread = new Thread(() -> {
    // 线程执行的代码
});
thread.start();

// 检查线程是否存活
if (thread.isAlive()) {
    System.out.println("线程正在运行");
}

// 获取线程状态
Thread.State state = thread.getState();
System.out.println("线程状态: " + state);

实现UncaughtExceptionHandler

通过实现UncaughtExceptionHandler接口可以监听线程中未捕获的异常。

Thread.setDefaultUncaughtExceptionHandler((t, e) -> {
    System.out.println("线程 " + t.getName() + " 抛出异常: " + e.getMessage());
});

Thread thread = new Thread(() -> {
    throw new RuntimeException("测试异常");
});
thread.start();

使用线程池的监听

通过自定义线程池或使用ThreadPoolExecutor的钩子方法监听线程活动。

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    2, 4, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>()
) {
    @Override
    protected void beforeExecute(Thread t, Runnable r) {
        System.out.println("线程 " + t.getName() + " 开始执行任务");
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        System.out.println("线程 " + Thread.currentThread().getName() + " 完成任务");
    }
};

executor.submit(() -> {
    // 任务代码
});

通过Future监听任务状态

使用Future对象可以监听提交给线程池的任务状态。

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<?> future = executor.submit(() -> {
    // 任务代码
});

// 检查任务是否完成
if (future.isDone()) {
    System.out.println("任务已完成");
}

自定义监听器模式

通过自定义监听器接口实现线程活动的监听。

java如何监听线程

interface ThreadListener {
    void onThreadStart(Thread thread);
    void onThreadFinish(Thread thread);
}

class MonitoredThread extends Thread {
    private final ThreadListener listener;

    MonitoredThread(Runnable target, ThreadListener listener) {
        super(target);
        this.listener = listener;
    }

    @Override
    public void run() {
        listener.onThreadStart(this);
        super.run();
        listener.onThreadFinish(this);
    }
}

// 使用示例
ThreadListener listener = new ThreadListener() {
    @Override
    public void onThreadStart(Thread thread) {
        System.out.println("线程启动: " + thread.getName());
    }

    @Override
    public void onThreadFinish(Thread thread) {
        System.out.println("线程结束: " + thread.getName());
    }
};

new MonitoredThread(() -> {
    // 线程代码
}, listener).start();