executorservice

    9热度

    3回答

    的​​有以下方法: Future<?> submit(Runnable task) 但由于这Future的get方法将总是返回null不会以下签名更合适? Future<Void> submit(Runnable task)

    4热度

    3回答

    要求: 我有留言分为不同类型e.g Type1, Type2 ... Type100。 我想以并行执行不同类型的消息。我们假设在10个线程中,但是所有相同类型的消息必须一个接一个地执行。执行顺序无关紧要。 一旦线程完成所有的TypeX消息。它应该开始处理另一个类型。 我经历了不同的答案: 他们中的大多数人建议执行程序服务来处理多线程。 比方说,我们创建一个像 ExecutorService exe

    0热度

    1回答

    假设我有一个共同执行调用这样的两个类: public class blah { @Autowired private ExecutorServiceUtil executorServiceUtil; @Autowired private RestTemplate restClient; public SomeReturnType getDepositTransactions(Htt

    3热度

    1回答

    我需要对具有零循环的长时间运行函数进行时间限制。我使用Callable运行该功能,并以超时值调用get。 AFAIU,future.cancel(true)将为函数线程设置中断标志。但直到除非我检查并处理longRunningFunction()中的Thread.isInterrupted(),我的代码将不知道它必须退出,并且即使在shutdownNow()之后,该函数也不会终止。 如何检查中断l

    0热度

    1回答

    此问题与我在Java并发性主题中的家庭作业分配有关。我的任务是产生新的线程,并限制它们给定的concurrencyFactor。也就是说,不断调度新线程,直到活动线程的数量小于或等于concurrencyFactor。如果活动线程的数量等于concurrencyFactor,程序将等待直到活动线程数减少到concurrencyFactor - 1并创建一个新线程。 作为第一种方法,我使用Execu

    4热度

    1回答

    我用例: 设置最小大小“N”对于这意味着“N”螺纹总是执行人启动后的可用线程池。 设置线程池的最大大小'M'。 当所有'M'线程忙时,传入任务应该排队。 基于空闲状态超时期满(M-N)线程。 我相信HttpClient后面的池管理器可能有类似的设置。我试图用ThreadPoolExecutor来实现它,但无法找到一种方法。可能吗? 这是一个测试的例子。 public class ExecutorE

    0热度

    1回答

    等待future.isDone()== true返回调用线程(main)的标准方法是什么? 我试着通过一个asyncMethod()在调用线程(主线程)上返回一个结果。 asyncMethod()立即返回,但在返回之前,首先触发一个导致广播意图回到主线程的进程。在主线程中,我检查future.isDone(),但不幸的是,future.isDone()仅在一半时间返回true。 Executor

    0热度

    1回答

    我创建了一个值为5的线程池。将任务分配给5个线程之后,工作者应该等待创建线程,直到线程在线程池中获得空闲为止。那么,如何找到线程池中的任何线程都是免费的? 在此先感谢....

    0热度

    2回答

    我应该在每个方法调用中创建新的ExecutorService还是每个类使用一个?在性能方面哪个是首选? public class NotificationService { public void sendNotification(User recipient) { ExecutorService notificationsPool = Executors.newFixe

    0热度

    1回答

    我正在开发一个使用IBM j9 JDK的应用程序。当我尝试使用下面的代码行: ExecutorService es = Executors.newSingleThreadExecutor(); 我得到一个运行时异常说的NoClassDefFoundError为java.util.Executors 是否有不同的方式,我可以打开使用IBM J9并发线程?