Java多线程：如何实现线程协作

在Java中，线程协作可以通过以下几种方式实现：

1. 使用wait()和notify()方法： 这两个方法用于线程间的协作，它们是Object类的成员方法。当一个线程调用某个对象的wait()方法时，该线程会释放该对象的锁并进入等待状态。当另一个线程调用同一个对象的notify()方法时，等待该对象的线程会被唤醒并重新获取锁。这样可以实现线程间的协作。

示例：

public class ThreadCooperation {
    private static final Object lock = new Object();

    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            synchronized (lock) {
                try {
                    System.out.println("Thread 1 waiting...");
                    lock.wait();
                    System.out.println("Thread 1 resumed.");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        Thread t2 = new Thread(() -> {
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (lock) {
                System.out.println("Thread 2 notifying...");
                lock.notify();
                System.out.println("Thread 2 finished.");
            }
        });

        t1.start();
        t2.start();
    }
}

2. 使用join()方法： join()方法用于等待一个线程完成其任务。当一个线程调用另一个线程的join()方法时，当前线程会阻塞，直到被调用的线程完成任务。

示例：

public class ThreadCooperation {
    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            System.out.println("Thread 1 started.");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Thread 1 finished.");
        });

        Thread t2 = new Thread(() -> {
            try {
                System.out.println("Thread 2 started.");
                t1.join();
                System.out.println("Thread 2 finished.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        t1.start();
        t2.start();
    }
}

3. 使用CountDownLatch类： CountDownLatch是一个同步辅助类，它允许一个或多个线程等待其他线程完成操作。通过使用CountDownLatch，可以实现线程间的协作。

示例：

import java.util.concurrent.CountDownLatch;

public class ThreadCooperation {
    public static void main(String[] args) {
        int numberOfThreads = 2;
        CountDownLatch latch = new CountDownLatch(numberOfThreads);

        Thread t1 = new Thread(() -> {
            System.out.println("Thread 1 started.");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Thread 1 finished.");
            latch.countDown();
        });

        Thread t2 = new Thread(() -> {
            try {
                latch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Thread 2 started.");
            System.out.println("Thread 2 finished.");
        });

        t1.start();
        t2.start();
    }
}

4. 使用CyclicBarrier类： CyclicBarrier是一个同步辅助类，它允许一组线程互相等待，直到所有线程都准备好继续执行。通过使用CyclicBarrier，可以实现线程间的协作。

示例：

import java.util.concurrent.CyclicBarrier;

public class ThreadCooperation {
    public static void main(String[] args) {
        int numberOfThreads = 2;
        CyclicBarrier barrier = new CyclicBarrier(numberOfThreads, () -> {
            System.out.println("All threads are ready.");
        });

        Thread t1 = new Thread(() -> {
            System.out.println("Thread 1 started.");
            try {
                Thread.sleep(3000);
                barrier.await();
                System.out.println("Thread 1 finished.");
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

        Thread t2 = new Thread(() -> {
            System.out.println("Thread 2 started.");
            try {
                barrier.await();
                System.out.println("Thread 2 finished.");
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

        t1.start();
        t2.start();
    }
}

这些方法可以帮助您实现Java多线程间的协作。根据您的需求选择合适的方法。