8得票3回答
Java: SingleThreadScheduledExecutor & java.util.concurrent.RejectedExecutionException Java:SingleThreadScheduledExecutor和java.util.concurrent.RejectedExecutionException

I am having this problem, I have private ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); 每50毫秒创建一个任务:...

15得票2回答
Java中运行基于CPU的简单程序,最佳线程池大小是多少?

我正在使用线程池来执行任务,这些任务大多是基于CPU的,带有一点I/O操作,线程池大小为CPU数量加1。Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() + 1) 假设有一个简单的程序,将所有任务提交...

33得票2回答
asyncio:是否可以取消由Executor运行的future?

我想使用异步调用的loop.run_in_executor方法在Executor中启动一个阻塞函数,然后稍后取消它,但这似乎对我不起作用。以下是代码:import asyncio import time from concurrent.futures import ThreadPoolExe...

24得票3回答
如何在API级别小于28的情况下获取主线程的执行器

在API 28(Pie)级别中,Context类引入了一种新方法,用于获取主线程的Executor:getMainExecutor()。 如何在低于28的API级别上获取此执行器?

7得票1回答
有没有 Executor 的使用场景而不是 ExecutorService?Executor 接口的目的是什么?

我想知道是否有使用Executor而不是ExecutorService的理由。 据我所知,JDK中实现了Executor接口的所有对象都同时是ExecutorService,这意味着您必须关闭服务以避免内存泄漏。您不能关闭Executor,但可以通过ExecutorService来做到这一点...

9得票1回答
"Runnable::run" - 这是如何创建Executor实例的?

我正在处理一个项目,在其中使用以下代码行来创建测试Executor成员变量实例: ```java private Executor executor = Runnable::run; ``` 该代码可以运行和编译,但我不明白 `Runnable::run` 如何创建 `Executor` ...

37得票4回答
Java Executor最佳实践:用于永久运行任务的任务

我正在开发一个Java项目,需要异步运行多个任务。我听说Executor是实现该功能的最佳方式,因此我正在熟悉它。(耶,通过学习赚钱!)但是,我不清楚实现我想做的事情的最佳方法。 为了举例说明,假设我有两个任务正在运行。这两个任务都不会终止,并且应该在应用程序运行期间一直运行。我正在编写一个...

76得票10回答
当ThreadPoolExecutor的队列已满时会阻塞吗?

我正在尝试使用ThreadPoolExecutor执行大量任务。以下是一个假设的示例:def workQueue = new ArrayBlockingQueue<Runnable>(3, false) def threadPoolExecutor = new ThreadPool...

7得票2回答
Java CompletableFuture 组合使用的线程?

我开始逐渐熟悉Java中的CompletableFuture组合,之前我已经用过JavaScript的promise了。基本上,这种组合只是在指定的执行器上安排链接的命令。但我不确定组合执行时是哪个线程在运行。 假设我有两个执行器:executor1和executor2;为了简单起见,我们假...

17得票3回答
Python中多个线程同时写入同一个CSV文件

我是 Python 中的多线程新手,目前正在编写一个将数据添加到 CSV 文件中的脚本。如果我要提交多个线程到一个 concurrent.futures.ThreadPoolExecutor,这些线程只会执行一个将行添加到 CSV 文件的操作,那么我该如何保证线程安全呢? 我的代码简化版:w...