阅读量:78
在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(); // 关闭线程池
}
}