Java多线程编程

本文中简单介绍一些java多线程相关的内容

1. 多线程基础

Java通过java.lang.Thread类和java.util.concurrent包提供了多线程支持。一个线程可以通过继承Thread类或实现Runnable接口来创建。

class MyThread extends Thread {
    public void run() {
        // 线程执行的代码
    }
}

// 启动线程
MyThread myThread = new MyThread();
myThread.start();

2. 线程同步与互斥

在多线程环境下，可能会涉及到共享资源的读写问题。为了防止数据不一致或者产生竞态条件需要使用同步机制。Java提供了synchronized关键字来实现同步：

class SharedResource {
    private int count = 0;

    public synchronized void increment() {
        count++;
    }
}

3. 线程间通信

Java提供了wait()、notify()和notifyAll()等方法来实现线程的通通信

class SharedResource {
    private boolean flag = false;

    public synchronized void produce() {
        while (flag) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 生产操作
        flag = true;
        notify();
    }

    public synchronized void consume() {
        while (!flag) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 消费操作
        flag = false;
        notify();
    }
}

4. 线程池的使用

Java的Executor框架提供了线程池的支持：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        for (int i = 0; i < 10; i++) {
            executorService.execute(() -> {
                // 线程执行的代码
            });
        }

        executorService.shutdown();
    }
}