我有一个在套接字连接上创建新线程的应用程序。我想从这个线程提交一个Callable到一个ExecutorService。Callable需要通过命令行参数执行程序，所以我不想通过连接线程来执行。问题是，我不知道如何将Callable提交给一个设置了线程数的ExecutorService。我曾经考虑过使用单例并编写一个submit方法来将我的Callable
浏览 0提问于2012-04-24得票数 0
回答已采纳
在深入讨论细节之前，我想说，所有的东西都是使用线程工作的。我想使用ThreadPoolExecutor。我无法理解ThreadPoolExecutor在我的情况下是如何工作的。我想用ThreadPoolExecutor来转换这个过程，我在互联网上和我看到的任何地方都看过例子。executor.execute(new RecieveThread(threadCounter.toStr
浏览 7提问于2013-07-23得票数 0
回答已采纳
1回答
多线程池集成
、、
在我的主流中，我有一个线程池ExecutorService，我用一个“已知”的可调用数填充它，即i invokeAll()。还有另一个名为“ExecutorService”的globalPool对象(我认为ExecutorService是线程安全的，我可以从不同的线程向它添加任务)。现在，上面的每个调用都会产生新的任务，并将它们(提交)放到这个共享的"globalPool“中。
问题是，我无法知道(无法阻止)何时完成所有任务，以及是否有更多的
浏览 1提问于2013-06-05得票数 0
2回答
我正在开发一些最终将被多线程化的代码，使用线程池。线程池执行的任务将进行回调，并(有时)将进一步的任务提交到任务队列中。我想先开发单线程代码，得到正确的代码(我使用的是测试驱动的开发)，然后进行修改以确保线程安全(锁等)。要做到这一点，我需要一个非线程安全代码可以安全使用的Executor。我认为这意味着我需要一个单线程的Executor。也就是说，它会导致所有工作都由调用线程完成。JRE提供这样的Executor吗？或者是否可以将其
浏览 0提问于2018-11-06得票数 4
回答已采纳
我正在使用ExecutorCompletionService提交一些任务。然后我想等待最大值，比如5秒，然后停止处理。= new ExecutorCompletionService<String>(List<Callable<String>> callablesname taskCompletionS
浏览 2提问于2015-09-27得票数 1
所以重新提交
--我的问题是如何获得一个ExecutorService，以认识到线程立即无效(Null)，而不必等待将来的get。我有一个用例，在ThreadFactory中创建线程时，如果不能正确设置线程，我希望返回null (例如，它不能连接到服务器)。当ExecutorService运行可调用的提交并且ThreadFactory返回null时，代码将运行，但将在future.get(5，TimeUnit.SECONDS)等待，然后抛出一个Time
浏览 6提问于2017-01-05得票数 0
回答已采纳
1回答
现在，我有一段代码可以联系另一个服务器，询问某个项目是否在列表中，并根据返回的值返回一个布尔值。public boolean checkIfOnline(int accountId) { while (isCheckingIfOnline) { Thread.sleep(1);
浏览 0提问于2012-08-09得票数 0
回答已采纳
所以我怀疑Thread.yield()可能会产生这样的场景，因为调用这个代码流的所有报告都具有相同的线程优先级。我不确定Thread.yield在这个流中的使用情况，因为这是一个遗留应用程序，所以如果这样的代码会导致线程的无限等待状态，那么有人能指导我吗？reportName) { CallableexecutorService =
浏览 8提问于2022-01-17得票数 0
3回答
for-循环中完成的工作，并在继续打印result之前验证线程是否都已结束。但是，我遇到的问题是，在我的程序中经常会出现上述for-循环线程，这会导致大量开销，这是由于线程的创建和垃圾收集造成的。因此，我正在考虑使用ThreadPoolExecutor修改我的代码。然后，给出中间结果的线程将在下一次执行中被重用(在本例中是求和)。
由于我将中间结果存储在一个大小必须事先知道的数组中，所以我考虑使用一个大小固定的线程池。还是更好地使用由方法ExecutorService创建的Executo
浏览 2提问于2014-03-12得票数 2
回答已采纳
3回答
大多数这些调用所做的一件事就是将数据放入会话中，其中一两个可能会将数据放入会话中的同一对象中，因此线程安全可能是一个需要考虑的问题。
有没有人能建议一种同时调用所有这些的好方法？
浏览 1提问于2012-09-14得票数 4
回答已采纳
ExecutorService包含以下方法：我对术语submit与invoke的用法感到困惑。这是否意味着invokeXyz()方法会通过底层线程池立即调用这些任务，而submit()则会对提
浏览 4提问于2020-04-06得票数 0
4回答
collection} 我读过关于Runnable对象的文章，它可以用来将进程分割成几个线程implements Runnable public void run() //do something and add to StringBuilder} 如何实现将进程拆分为多个线程目标
浏览 11提问于2017-11-13得票数 1
回答已采纳
2回答
我有一个线程池( Thread Pool )为10的executor服务，我希望能得到10条打印出语句，间隔3秒，但我只收到一条打印输出语句。我传递了10作为参数，因此我希望运行10个线程。如何检索未来的10个对象？public class Demo {
Arr
浏览 2提问于2016-11-04得票数 0
回答已采纳
我使用Java的ExecutorService在一个IndexPage中并发调用12个Callables。每个Callable只是向一个链接发出一个http请求，并执行一些解析和数据库存储操作。在运行时，看起来还可以，我可以很好地观察到线程的工作/调度。每个链接的解析/存储只需要大约1到2秒。
CPU/Memory/He
浏览 1提问于2013-12-17得票数 4
2回答
我正在使用ExecutorService运行一些可调用的线程。线程在提交到ExecutorService之前使用数据进行初始化。可以从Future对象返回到创建它的原始线程吗？List<Future<Foo>> results = new ArrayList<Future<Foo>>(); Callable<Foo&g
浏览 1提问于2013-05-25得票数 1
回答已采纳
1回答
，并将一个任务提交给它进行异步计算。因此，asynchronous computation是如何在内部创建线程并提交我们在实例化FutureTask时赋予它的任务，比如：否则，它不可能是异步计算，请向我提供来自FutureTask 的代码片段，它将任务提交给线程，使其成为异步计算。，它基本上是试图在与调用者的线程相同的线程中运行任务。很明显，在给定的代码中
浏览 1提问于2013-11-04得票数 8
回答已采纳
2回答
我尝试使用ExecutorService及其线程池，但是如果我将ExecutorService声明为类字段并开始向其提交工作，则在某个时候它会抛出一个 public Integer call()return 0;});
Future<
浏览 5提问于2016-03-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
