理解并解决Java并发多线程问题-蒲公英云

理解并解决Java并发多线程问题

原创灰太狼 2024-10-14 01:30 215阅读 0赞

在Java中，处理并发多线程问题主要涉及以下几个方面：

线程创建：通过Thread类或者ExecutorService的submit()或call()方法创建线程。

Thread thread = new Thread(new Runnable() {
    @Override
    public void run() {
        // 线程内的逻辑
    }
}));
thread.start();

同步与互斥：使用synchronized关键字或者Lock接口实现线程间的互斥和同步。

public class Counter {
    private int count;
    // synchronized 同步方法
    public synchronized void increment() {
        count++;
    }
    // synchronized 返回当前值
    public synchronized int value() {
        return count;
    }
}

线程池：当需要管理大量线程时，可以使用ExecutorService来创建线程池。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);
        // 提交任务到线程池，线程池会根据情况自动分配给线程
        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerTask(i);
            executor.execute(worker);
        }
        // 关闭线程池，清理资源
        executor.shutdown();
        while (!executor.isTerminated()) {
            // 空等待，直到所有任务完成
        }
    }
}
class WorkerTask implements Runnable {
    private int taskNumber;
    public WorkerTask(int taskNumber) {
        this.taskNumber = taskNumber;
    }
    @Override
    public void run() {
        System.out.println("Worker " + taskNumber + " is running...");
        // 这里是执行任务的代码，可以根据需要替换
    }
}