import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ConcurrentTaskManager { private ExecutorService executorService; public ConcurrentTaskManager(int maxThreads) { executorService = Executors.newFixedThreadPool(maxThreads); } public void executeTask(Runnable task) { executorService.execute(task); } public void shutdown() { executorService.shutdown(); } public static void main(String[] args) { ConcurrentTaskManager taskManager = new ConcurrentTaskManager(5); for (int i = 0; i < 10; i++) { taskManager.executeTask(() -> { }); } taskManager.shutdown(); } }


上一篇:
下一篇:
切换中文