【问题标题】:Confused on Java ThreadPool对 Java ThreadPool 感到困惑
【发布时间】:2014-03-29 17:56:22
【问题描述】:

这是我第一次在我的新项目中使用 Java 线程池,在我遇到这个之后 链接http://www.javacodegeeks.com/2013/01/java-thread-pool-example-using-executors-and-threadpoolexecutor.html,我对此比较困惑,这是页面中的代码,

package com.journaldev.threadpool;

public class WorkerThread implements Runnable {

    private String command;

    public WorkerThread(String s){
        this.command=s;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+' Start. Command = '+command);
        processCommand();
        System.out.println(Thread.currentThread().getName()+' End.');
    }

    private void processCommand() {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Override
    public String toString(){
        return this.command;
    }
}


package com.journaldev.threadpool;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SimpleThreadPool {

    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5);
        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerThread('' + i);
            executor.execute(worker);
          }
        executor.shutdown();
        while (!executor.isTerminated()) {
        }
        System.out.println('Finished all threads');
    }

}

在代码中,创建了一个固定大小的池,并创建了 10 个工作线程,对吗?

线程池本应减轻系统的负担,相反,在上面的代码中,我认为除了工作线程之外,还通过创建池来增加负担。为什么要使用线程池?

谁能解释一下? 谢谢

我还在 StackOverflow 上阅读了这篇文章 http://stackoverflow.com/questions/19765904/how-threadpool-re-use-threads-and-how-it-works 它也没有帮助我。

【问题讨论】:

    标签: java multithreading threadpool


    【解决方案1】:

    这很令人困惑,因为 Runnable 被命名为 WorkerThread,但它们没有扩展 java.lang.Thread,它们只是实现 Runnable 的对象。实现 Runnable 允许您指定需要执行的任务,而无需实例化实际的 Thread 对象。在您的示例中创建的唯一线程是主线程和由 Executor 创建的线程。

    请注意,即使您更改此代码以使 WorkerThread 扩展 Thread,只要代码不对它们调用 start 就不会导致更多线程实际运行。构造线程对象涉及到一些事情,比如检查安全管理器和初始化线程局部变量,但它实际上并没有在操作系统级别做任何事情来分配线程。就 Executor 而言,它们只是 Runnables,它会使用线程池的线程来执行它们。

    【讨论】:

      【解决方案2】:

      不好的例子! WorkerThread 这个类不是线程,它是一个“任务”。

      线程隐藏在 ExecutorService 中。该示例创建了一个具有五个“工作”线程的 ExecutorService,它创建了十个任务,它要求执行器服务“执行”它们,最后,它等待所有任务完成。完全由 ExecutorService 决定如何、何时以及在哪个工作线程中执行每个任务。

      该示例的另一个较小问题是主线程在请求​​执行程序服务关闭后如何等待。它使用可能已被一个或多个工作人员使用的 CPU 资源旋转(取决于主机有多少 CPU 可用于运行各种线程。)等待循环应该调用 Thread.yield() 放弃每次调用主线程的时间片到任何其他可运行线程。

      【讨论】:

      • 感谢您的澄清
      猜你喜欢
      • 2018-10-03
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多