在Java中,创建新线程有两种主要方法:
class MyThread extends Thread {
public void run() {
// 线程执行的代码
}
}
public class Main {
public static void main(String[] args) {
MyThread myThread = new MyThread();
myThread.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(); // 关闭线程池
}
}