当前位置：首页 > 行业动态 > 正文

Java开启多线程的常见方法有哪些

admin
行业动态
2024-01-19
2

Java开启多线程的常见方法有继承Thread类、实现Runnable接口和使用Callable与Future。

Java开启多线程的常见方法有哪些

在Java中，有多种方法可以开启多线程，以下是一些常见的方法：

1、继承Thread类

2、实现Runnable接口

3、使用Callable和Future

4、使用线程池

下面我们详细介绍这四种方法。

1、继承Thread类

创建一个新的类，继承自Thread类，然后重写run()方法，在run()方法中编写需要执行的任务，最后创建该类的对象，并调用start()方法启动线程。

class MyThread extends Thread {
    @Override
    public void run() {
        // 在这里编写需要执行的任务
    }
}
public class Main {
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start(); // 启动线程
    }
}

2、实现Runnable接口

创建一个新的类，实现Runnable接口，然后重写run()方法，在run()方法中编写需要执行的任务，接下来，创建一个Thread对象，将实现了Runnable接口的类的实例作为参数传递给Thread类的构造函数，最后调用Thread对象的start()方法启动线程。

class MyRunnable implements Runnable {
    @Override
    public void run() {
        // 在这里编写需要执行的任务
    }
}
public class Main {
    public static void main(String[] args) {
        MyRunnable myRunnable = new MyRunnable();
        Thread thread = new Thread(myRunnable);
        thread.start(); // 启动线程
    }
}

3、使用Callable和Future

创建一个新的类，实现Callable接口，然后重写call()方法，在call()方法中编写需要执行的任务，接下来，创建一个ExecutorService对象，将实现了Callable接口的类的实例作为参数传递给ExecutorService的submit()方法，submit()方法返回一个Future对象，通过调用Future对象的get()方法获取任务执行结果，最后关闭ExecutorService对象。

import java.util.concurrent.*;
class MyCallable implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        // 在这里编写需要执行的任务，并返回结果
        return 0;
    }
}
public class Main {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        MyCallable myCallable = new MyCallable();
        Future<Integer> future = executorService.submit(myCallable); // 提交任务并获取Future对象
        int result = future.get(); // 获取任务执行结果
        executorService.shutdown(); // 关闭ExecutorService对象
    }
}

4、使用线程池

创建一个线程池，将任务提交给线程池执行，可以使用Executors工具类创建线程池，也可以自定义线程池，线程池可以有效地管理和控制线程的数量，提高系统性能。

import java.util.concurrent.*;
public class Main {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池，包含5个线程
        for (int i = 0; i < 10; i++) {
            executorService.submit(new MyRunnable()); // 将任务提交给线程池执行
        }
        executorService.shutdown(); // 关闭线程池，不再接收新的任务，等待已提交的任务执行完毕
    }
}