要实现Runnable任务的并发执行,可以使用Java中的线程池(ThreadPoolExecutor)或者Executors工具类。以下是两种方法的示例:
方法一:使用ThreadPoolExecutor
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class RunnableTask implements Runnable {
private int taskId;
public RunnableTask(int taskId) {
this.taskId = taskId;
}
@Override
public void run() {
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");
}
public static void main(String[] args) {
int numberOfTasks = 5;
ExecutorService executorService = Executors.newFixedThreadPool(numberOfTasks);
for (int i = 0; i < numberOfTasks; i++) {
RunnableTask task = new RunnableTask(i);
executorService.submit(task);
}
executorService.shutdown();
}
}
方法二:使用Executors工具类
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class RunnableTask implements Runnable {
private int taskId;
public RunnableTask(int taskId) {
this.taskId = taskId;
}
@Override
public void run() {
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");
}
public static void main(String[] args) {
int numberOfTasks = 5;
ExecutorService executorService = Executors.newFixedThreadPool(numberOfTasks);
for (int i = 0; i < numberOfTasks; i++) {
RunnableTask task = new RunnableTask(i);
executorService.submit(task);
}
executorService.shutdown();
}
}
这两种方法都可以实现Runnable任务的并发执行。ThreadPoolExecutor提供了更多的配置选项,例如核心线程数、最大线程数等。而Executors工具类提供了方便的方法来创建不同类型的线程池,例如固定大小的线程池、缓存线程池等。根据实际需求选择合适的方法。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。