Java

java 新建线程有哪些方式

小樊
82
2024-11-29 12:07:47
栏目: 编程语言

在Java中,创建新线程有两种主要方法:

  1. 继承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(); // 启动线程
    }
}
  1. 实现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<String> {
    public String call() throws Exception {
        // 任务执行的代码,返回结果
        return "任务结果";
    }
}

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

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

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

0
看了该问题的人还看了