温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Runnable任务如何并发执行

发布时间:2025-11-02 13:49:12 来源:亿速云 阅读:106 作者:小樊 栏目:编程语言

要实现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工具类提供了方便的方法来创建不同类型的线程池,例如固定大小的线程池、缓存线程池等。根据实际需求选择合适的方法。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI
助
手