这是我第一次在我的新项目中使用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它也没有帮助我。
这很令人困惑,因为 Runnable 被命名为 WorkerThread,但它们不扩展 java.lang.Thread,它们只是实现 Runnable 的对象。实现 Runnable 允许您指定需要执行的任务,而无需实例化实际的 Thread 对象。在您的示例中创建的唯一线程是主线程和执行器创建的线程。
请注意,即使您更改此代码以使 WorkerThread 扩展 Thread,只要代码不调用它们的 start 就不会导致更多线程实际运行。构造线程对象涉及一些事情,例如检查安全管理器和初始化线程局部变量,但它实际上并没有在操作系统级别执行任何操作来分配线程。就 Executor 而言,它们只是 Runnables,它将使用线程池的线程来执行它们。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)