这是我第一次在我的新项目中使用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这对我也没有帮助。
坏榜样!名为WorkerThread的类不是线程,而是“任务”。
线程隐藏在Executor服务中。该示例创建了一个包含五个“工作”线程的executor服务,它创建了十个任务,它要求executor服务“执行”这些任务,最后,它等待所有任务完成。完全由ExecutorService决定如何、何时以及在哪个工作线程中执行每个任务。
该示例的另一个较小的问题是主线程在请求executor服务关闭后如何等待。它使用可能被一个或多个工作人员使用的CPU资源进行旋转(取决于主机有多少CPU可用于运行各种线程)等待循环应该调用线程。yield(),每次调用主线程时,它都会将主线程的时间片交给任何其他可运行线程。
这很令人困惑,因为Runnables被命名为WorkerThread,但它们并没有扩展java.lang.Thread,它们只是实现Runnable的对象。实现Runnable可以让您指定需要执行的任务,而无需实例化实际的Thread对象。在您的示例中创建的唯一线程是主线程和由执行器创建的线程。
请注意,即使更改此代码以使WorkerThread扩展线程,只要代码不对其调用start,也不会导致更多线程实际运行。构造一个线程对象涉及到一些事情,比如使用安全管理器检查和初始化threadlocals,但它实际上并没有在操作系统级别执行任何分配线程的操作。就执行器而言,它们只是可运行的,它将使用线程池的线程执行它们。
问题内容: 在碰到此链接http://www.javacodegeeks.com/2013/01/java-thread-pool-example-using- executors-and-threadpoolexecutor 之后,这是我第一次为新项目使用Java线程池。 .html ,我对此更加困惑,这是页面中的代码, 在代码中,创建了一个固定大小的池并创建了10个工作线程,对吗? 线程池应该
我正在尝试提出一种解决方案,它涉及在连接操作之后应用一些逻辑,从多个中的中选择一个事件。这类似于reduce函数,但它只返回1个元素,而不是递增地返回。因此最终结果将是单个(,对,而不是一个 每个键保证只到达一次。 假设像上面这样的连接操作,它用4个生成了1个,成功地连接并收集在。现在,我想做的是,立即访问这些值,并执行一些逻辑以将正确匹配到一个。例如,对于上面的数据集,我需要(,和)。 将为每个
所以我一直在读Kafka的语义学,我对它的工作原理有点困惑。 我理解生产者如何避免发送重复的消息(以防代理的ack失败),但我不明白的是,在消费者处理消息但在提交偏移量之前崩溃的情况下,一次是如何工作的。Kafka不会在这种情况下重试吗?
问题内容: 我已经在eclipse中创建了一个项目,并添加了Maven依赖项。在Eclipse中,它表示我正在使用JRE 1.5。一切在Eclipse中都可以正常运行,例如,我可以运行测试。 当我尝试从终端运行时,出现以下错误。 …在-source 1.3中不支持泛型(使用-source 5或更高版本来启用泛型)… 看来,Maven认为我正在使用JRE 1.3,并且无法识别泛型或for-each循
关于静态的东西: 类共享静态方法的实例 类似的问题: Java:何时使用静态方法 “静态”关键字在类中有什么作用? 我感到困惑的是: 静态方法只有一个内存块? 如果我在多线程中使用静态方法,会阻塞吗?
问题内容: 与此代码有点混淆。 我在pg-go 仓库中找到了这段代码,不知道为什么这样声明。请解释一下用这种方式声明变量的用例是什么。 问题答案: 这在运行时不会执行任何操作,但是除非类型满足接口要求,否则编译将失败。这是一种静态断言。