用 java 写一个多线程处理
时间: 2024-04-16 07:29:22 浏览: 81
java多线程与进程调度
好的,下面是 Java 多线程处理的代码示例:
```java
public class MultiThreadDemo {
public static void main(String[] args) {
int n = 10; // 任务数量
String[] tasks = new String[n]; // 任务列表
for (int i = 0; i < n; i++) {
tasks[i] = "Task " + i;
}
// 创建线程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交任务
for (int i = 0; i < n; i++) {
executorService.submit(new TaskProcessor(tasks[i]));
}
// 关闭线程池
executorService.shutdown();
}
/**
* 任务处理器
*/
static class TaskProcessor implements Runnable {
private String task;
public TaskProcessor(String task) {
this.task = task;
}
@Override
public void run() {
// 执行任务
System.out.println("Processing task: " + task);
}
}
}
```
上面的代码中,我们创建了一个 `MultiThreadDemo` 类,其中包含了一个 `main` 方法,用于演示多线程处理的过程。我们首先定义了任务数量和任务列表,然后创建了一个线程池 `executorService`,并设置线程池的大小为 5。接下来,我们使用 `for` 循环提交任务给线程池,每个任务都是一个 `TaskProcessor` 的实例。最后,我们关闭线程池。
`TaskProcessor` 类表示任务处理器,实现了 `Runnable` 接口,用于执行具体的任务。在 `run` 方法中,我们只是简单地输出了任务的名称,实际应用中可以根据具体的需求,执行一些更加复杂的任务操作。
阅读全文