时间戳

首页 > 解决方案 > 如何分析Java中的多线程开销？

java - 如何分析Java中的多线程开销？

问题描述

我的程序如下所示：

Executor executor = Executors.newSingleThreadExecutor();

void work1(){
    while (true) {
        // do heavy work 1
        Object data;
        executor.execute(() -> work2(data));
    }
}

void work2(Object data){
    // do heavy work 2
}

我注意到，当work2变得沉重时，它work1也会影响。将进程分成两个线程几乎没有任何好处。

这种行为的原因可能是什么？我必须使用什么工具来查找和分析这些问题？

哦，这是我的机器规格：

在此处输入图像描述

标签： javamultithreadingperformance

解决方案

"while (true) {}" 工作速度很快，但 work2 很重而且工作很慢。结果，等待单线程的任务数无限增加。所以可用的核心内存耗尽，使用虚拟内存，速度要慢得多。标准线程池不是为处理大量任务而设计的。正确的解决方案如下：

class WorkerThread extends Thread {
    ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(10);
    public void run() {
        while true() {
           queue.take().run();
        }
     }
}

WorkerThread  workerThread = new WorkerThread();
workerThread.start();

void work1(){
    while (true) {
        Object data;
        // do heavy work
        workerThread.queue.put(() -> work2(data));
    }
 }

使用ArrayBlockingQueue可以减少等待任务的数量。

推荐阅读