jjzjj

newFixedThreadPool

全部标签

java - 多个 newSingleThreadExecutor 与 ExecutorService 的 newFixedThreadPool

在我的应用程序中,我有4个不同的进程,它们永久运行,中间有一些小的停顿。当前版本的代码在单独的老式线程中执行每个进程:ThreadnlpAnalyzer=newThread(()->{//infinelopforautorestoreincaseofcrash//noinspectionInfiniteLoopStatementwhile(true){try{//thismethodshouldrunpermanently,pausesimplementedinternallyNLPAnalyzer.analyzeNLP(dbCollection);}catch(Exceptione)

java - 生产者消费者——使用Executors.newFixedThreadPool

我对生产者-消费者模式的理解是,它可以使用生产者和消费者之间共享的队列来实现。生产者将工作提交到共享队列,消费者检索并处理它。也可以通过生产者直接提交给消费者来实现(Producer线程直接提交给Consumer的executor服务)。现在,我一直在研究提供线程池一些常见实现的Executors类。根据规范,newFixedThreadPool方法“重用固定数量的线程,这些线程在共享的无界队列中运行”。他们在这里谈论哪个队列?如果Producer直接提交任务给consumer,ExecutorService的内部队列是否包含Runnables列表?或者它是中间队列,以防生产者提交到共

java - IntelliJ 无法解析符号 "newFixedThreadPool"

这个问题在这里已经有了答案:Whatdoesa"Cannotfindsymbol"or"Cannotresolvesymbol"errormean?(18个答案)关闭5年前。总的来说,我是IntelliJ和Java的新手。我正在尝试学习多线程并且遇到了Executors类。所以我想对此进行测试,这是我的代码示例。importjava.util.List;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;publicclassLegController{privateListle

java - 如何决定使用newCachedThreadPool还是newFixedThreadPool?

我正在做一个项目,我需要确保每个线程都在特定范围内工作。例如:NO_OF_THREADS:2NO_OF_TASKS:10如果线程数为2,任务数为10,则每个线程将执行10个任务。所以这意味着2个线程将执行20个任务。在实际情况下,这些数字(任务数和线程数)将非常高,因为它们都可以在我的代码中配置。在上面的例子中,第一个线程应该使用1和10之间的id,第二个线程应该使用之间的id11和20如果有更多线程,依此类推。之后每个线程都会建立一个数据库连接,然后插入到数据库中。所以我的以下代码运行良好。publicstaticvoidmain(String[]args){finalintnoOf

java - 如何使用固定数量的工作线程实现简单线程

我正在寻找最简单、最直接的方法来实现以下内容:主程序实例化worker线程来执行任务。一次只能运行n个任务。当达到n时,不再有worker开始直到计数正在运行的线程回落到n以下。 最佳答案 我认为Executors.newFixedThreadPool符合您的要求。有许多不同的方法可以使用生成的ExecutorService,这取决于您是否希望将结果返回到主线程,或者任务是否完全独立,以及您是否有一组任务要预先执行,或者任务是否排队以响应某些事件。Collectiontasks=newArrayList();YourTaskyt1=

java - 如何使用固定数量的工作线程实现简单线程

我正在寻找最简单、最直接的方法来实现以下内容:主程序实例化worker线程来执行任务。一次只能运行n个任务。当达到n时,不再有worker开始直到计数正在运行的线程回落到n以下。 最佳答案 我认为Executors.newFixedThreadPool符合您的要求。有许多不同的方法可以使用生成的ExecutorService,这取决于您是否希望将结果返回到主线程,或者任务是否完全独立,以及您是否有一组任务要预先执行,或者任务是否排队以响应某些事件。Collectiontasks=newArrayList();YourTaskyt1=

java - Executors.newFixedThreadPool(1) 和 Executors.newSingleThreadExecutor() 的区别

我的问题是:使用Executors.newFixedThreadPool(1)有意义吗??。在两个线程(main+oneAnotherThread)场景中使用执行器服务是否有效?通过调用newRunnable(){}直接创建新线程是否比使用ExecutorService更好?在这种情况下使用ExecutorService有哪些优点和缺点?PS:主线程和oneAnotherThread不访问任何公共(public)资源。我已经完成了:WhataretheadvantagesofusinganExecutorService?.和Onlyonethreadatatime!

java - Executors.newCachedThreadPool() 与 Executors.newFixedThreadPool()

newCachedThreadPool()与newFixedThreadPool()相比我什么时候应该使用其中一种?在资源利用方面哪种策略更好? 最佳答案 我认为文档很好地解释了这两个函数的区别和用法:newFixedThreadPoolCreatesathreadpoolthatreusesafixednumberofthreadsoperatingoffasharedunboundedqueue.Atanypoint,atmostnThreadsthreadswillbeactiveprocessingtasks.Ifaddit

在项目中使用——newFixedThreadPool线程池

newFixedThreadPool线程池前言newFixedThreadPool的介绍使用newFixedThreadPool的步骤实例化一个固定线程大小线程池创建一个用于启动新线程的类使用submit提交线程最后关闭关闭线程池CountDownLatch配合线程池使用构造CountDownLatch计数器减一使调用该方法的线程处于等待状态,当倒数到0时主线程才执行。示例:使用线程池的方式,计算1000名学生的学习数据Main类,用于初始化线程池大小、线程提交任务CalculationStudentsData类:用于执行线程,并执行具体的业务执行结果的部分截图思考如果博主的文章对您有所帮助,

在项目中使用——newFixedThreadPool线程池

newFixedThreadPool线程池前言newFixedThreadPool的介绍使用newFixedThreadPool的步骤实例化一个固定线程大小线程池创建一个用于启动新线程的类使用submit提交线程最后关闭关闭线程池CountDownLatch配合线程池使用构造CountDownLatch计数器减一使调用该方法的线程处于等待状态,当倒数到0时主线程才执行。示例:使用线程池的方式,计算1000名学生的学习数据Main类,用于初始化线程池大小、线程提交任务CalculationStudentsData类:用于执行线程,并执行具体的业务执行结果的部分截图思考如果博主的文章对您有所帮助,
12