java中实现多线程的几种方法

发布时间:2024-12-07 08:27:36

阅读量:80

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

继承Thread类：创建一个类，继承自Thread类，并重写其run()方法。然后创建该类的实例，并调用start()方法来启动新线程。

class MyThread extends Thread {
    public void run() {
        // 线程执行的代码
    }
}

public class Main {
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start();
    }
}

实现Runnable接口：创建一个类，实现Runnable接口，并重写其run()方法。然后创建该类的实例，并将其传递给Thread类的构造函数。最后调用Thread类的start()方法来启动新线程。

class MyRunnable implements Runnable {
    public void run() {
        // 线程执行的代码
    }
}

public class Main {
    public static void main(String[] args) {
        MyRunnable myRunnable = new MyRunnable();
        Thread thread = new Thread(myRunnable);
        thread.start();
    }
}

使用Callable接口和Future：创建一个类，实现Callable接口，并重写其call()方法。然后使用ExecutorService框架来执行该任务，并获取Future对象。通过Future对象，可以获取任务执行的结果或取消任务。

import java.util.concurrent.*;

class MyCallable implements Callable {
    public Integer call() throws Exception {
        // 线程执行的代码，返回结果
        return 42;
    }
}

public class Main {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        Future future = executorService.submit(new MyCallable());
        Integer result = future.get(); // 获取任务执行的结果
        executorService.shutdown();
    }
}

使用Java 8的CompletableFuture：创建一个函数式接口，例如Function，然后使用CompletableFuture类的supplyAsync()方法异步执行该函数。通过CompletableFuture对象，可以获取任务执行的结果、异常或执行其他操作。

import java.util.concurrent.CompletableFuture;
import java.util.function.Function;

@FunctionalInterface
interface MyFunction {
    int apply(int input);
}

public class Main {
    public static void main(String[] args) {
        MyFunction myFunction = x -> x * 2;
        CompletableFuture future = CompletableFuture.supplyAsync(myFunction, 42);
        future.thenAccept(result -> System.out.println("Result: " + result)); // 获取任务执行的结果
    }
}