创建n个可以相互通信的线程

import java.util.ArrayList;
import java.util.List;

public class ThreadCommunicationExample {
    private static final Object lock = new Object();
    private static int sharedResource = 0;

    public static void main(String[] args) {
        int n = 5; // 创建5个线程
        List<Thread> threads = new ArrayList<>();

        for (int i = 0; i < n; i++) {
            threads.add(new Thread(new Worker(lock)));
        }

        for (Thread thread : threads) {
            thread.start();
        }
    }

    static class Worker implements Runnable {
        private final Object lock;

        public Worker(Object lock) {
            this.lock = lock;
        }

        @Override
        public void run() {
            synchronized (lock) {
                try {
                    while (sharedResource < 10) {
                        System.out.println(Thread.currentThread().getName() + " waiting...");
                        lock.wait();
                    }
                    System.out.println(Thread.currentThread().getName() + " proceeding with sharedResource = " + sharedResource);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        }
    }
}