在Java中启动多线程可以通过以下几种常见方法:
继承Thread类
创建一个继承自`Thread`类的子类,并重写`run()`方法来定义线程的逻辑。
通过调用子类的`start()`方法来启动线程。
```java
class MyThread extends Thread {
@Override
public void run() {
// 线程执行的代码
}
}
public class Main {
public static void main(String[] args) {
MyThread thread = new MyThread();
thread.start();
}
}
实现Runnable接口
创建一个实现了`Runnable`接口的类,并实现接口中的`run()`方法。
创建`Thread`对象,将`Runnable`对象作为参数传递给`Thread`的构造函数,并调用`Thread`的`start()`方法来启动线程。
```java
class MyRunnable implements Runnable {
@Override
public void run() {
// 线程执行的代码
}
}
public class Main {
public static void main(String[] args) {
MyRunnable runnable = new MyRunnable();
Thread thread = new Thread(runnable);
thread.start();
}
}
使用Callable和Future
创建一个实现`Callable`接口的类,并实现接口中的`call()`方法。
创建`ExecutorService`对象,通过`submit()`方法将`Callable`对象提交给`ExecutorService`,并返回一个`Future`对象。
通过`Future`对象可以获取线程执行的结果。
```java
class MyCallable implements Callable
@Override
public String call() throws Exception {
// 线程执行的代码
return "结果";
}
}
public class Main {
public static void main(String[] args) {
ExecutorService executor = Executors.newSingleThreadExecutor();
Future
try {
String result = future.get();
System.out.println(result);
} catch (Exception e) {
e.printStackTrace();
}
executor.shutdown();
}
}
使用线程池
通过创建`ThreadPoolExecutor`对象来创建线程池。
使用`execute()`方法或`submit()`方法将任务提交给线程池。
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个固定大小为 5 的线程池
ExecutorService executor = Executors.newFixedThreadPool(5);
// 向线程池提交 10 个任务
for (int i = 0; i < 10; i++) {
Runnable task = new MyTask(i);
executor.submit(task);
}
// 关闭线程池
executor.shutdown();
}
}
class MyTask implements Runnable {
private int taskId;
public MyTask(int taskId) {
this.taskId = taskId;
}
@Override
public void run() {
System.out.println("执行任务 " + taskId);
}
}
以上是Java中启动多线程的几种常见方法。请根据具体需求选择合适的方法