java 新建线程有哪些方式_运维文库_资讯中心

发布时间:2026-04-29 02:28:11

阅读量:2

在Java中，创建新线程有两种主要方法：

继承Thread类：创建一个新类，继承自java.lang.Thread类，并重写其run()方法。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接口：创建一个新类，实现java.lang.Runnable接口，并重写其run()方法。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(); // 启动线程
    }
}

另外，从Java 5开始，可以使用ExecutorService和Callable接口来更高效地创建和管理线程。这些方法提供了更好的资源利用和更强大的线程控制功能。

使用ExecutorService创建线程池：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池

        for (int i = 0; i < 10; i++) {
            executorService.submit(new MyRunnable()); // 提交任务到线程池
        }

        executorService.shutdown(); // 关闭线程池
    }
}

使用Callable接口获取任务结果：

import java.util.concurrent.*;

class MyCallable implements Callable {
    public String call() throws Exception {
        // 任务执行的代码，返回结果
        return "任务结果";
    }
}

public class Main {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池
        Future future = executorService.submit(new MyCallable()); // 提交任务到线程池并获取Future对象

        try {
            String result = future.get(); // 获取任务执行结果
            System.out.println("任务结果: " + result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        executorService.shutdown(); // 关闭线程池
    }
}