在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(); // 关闭线程池 } }