java实现多线程的几种方式

原创

ithorizon 8个月前 (08-31) 阅读数 98 #Java

Java实现多线程的几种方法

多线程是Java语言中的一个重要特性，它允许我们并行地执行多个操作。在Java中，有多种方法可以实现多线程，以下是几种常见的实现方法。

1. 继承Thread类

第一种方法是通过继承java.lang.Thread类，并重写run方法。然后创建该类的实例，并调用start方法来启动线程。


public class MyThread extends Thread {
    @Override
    public void run() {
        // 线程执行的代码
        System.out.println("线程运行中...");
    }
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start(); // 启动线程
    }
}

2. 实现Runnable接口

第二种方法是实现java.lang.Runnable接口的run方法，然后将该实现作为参数传递给Thread类的构造函数。这种方法更灵活，基于Java不赞成多重继承，实现Runnable接口可以让你的类继承其他类。


public class MyRunnable implements Runnable {
    @Override
    public void run() {
        // 线程执行的代码
        System.out.println("线程运行中...");
    }
    public static void main(String[] args) {
        MyRunnable myRunnable = new MyRunnable();
        Thread thread = new Thread(myRunnable);
        thread.start(); // 启动线程
    }
}

3. 使用Executor框架

Java 5引入了java.util.concurrent包，提供了Executor框架来管理线程。这简化了线程的使用和管理。


import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ExecutorExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个包含5个线程的线程池
        executorService.execute(new MyRunnable()); // 提交任务到线程池
        executorService.shutdown(); // 关闭线程池
    }
}

4. 使用Callable和Future

Java 5中引入的Callable接口与Runnable类似，但它允许返回因此或抛出异常。Future对象用于获取线程的执行因此。


import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
public class CallableExample {
    public static void main(String[] args) {
        FutureTask futureTask = new FutureTask<>(new Callable() {
            @Override
            public Integer call() throws Exception {
                // 线程执行的代码
                return 1;
            }
        });
        new Thread(futureTask).start(); // 启动线程
        try {
            Integer result = futureTask.get(); // 获取线程执行的因此
            System.out.println("线程返回因此：" + result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}