在Java中,您可以使用Executors工具类创建一个具有固定线程数量的线程池,从而限制并发任务数。以下是一个简单的示例:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Main {
public static void main(String[] args) {
// 创建一个固定大小的线程池,限制并发任务数为5
ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交10个任务到线程池
for (int i = 0; i < 10; i++) {
final int taskId = i;
executorService.submit(() -> {
System.out.println("Task " + taskId + " is running on thread " + Thread.currentThread().getName());
try {
Thread.sleep(1000); // 模拟任务执行时间
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Task " + taskId + " is completed");
});
}
// 关闭线程池
executorService.shutdown();
}
}
在这个示例中,我们创建了一个固定大小为5的线程池,这意味着最多只能有5个任务同时运行。当我们提交10个任务时,它们将被放入队列中等待,直到有线程可用。这样可以有效地限制并发任务数。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。