在Java中，多线程编程是提高应用程序性能的关键技术之一。通过合理地使用多线程，可以有效地利用现代多核处理器的计算能力，提升程序的响应速度和吞吐量。在这篇文章中，我们将深入探讨Java多线程编程中的等待与回调机制，帮助您轻松实现高效的任务处理。

等待与通知（Wait/Notify）

在Java中，线程之间的通信主要通过Object类的wait()、notify()和notifyAll()方法来实现。这些方法可以使得一个线程在某个对象上进行等待，直到另一个线程调用该对象的notify()或notifyAll()方法。

wait()

wait()方法是Object类的一个方法，当一个线程调用wait()方法时，它会释放当前对象的所有锁，然后进入等待状态，直到当前线程被其他线程唤醒。

synchronized (this) {
    while (条件不满足) {
        this.wait();
    }
    // 条件满足后的操作
}

notify()

notify()方法是用来唤醒一个在此对象监视器上等待的单个线程的。被唤醒的线程将等待重新获得对当前对象的监视器锁。

synchronized (this) {
    // 执行某些操作
    notify(); // 唤醒一个等待线程
}

notifyAll()

notifyAll()方法与notify()类似，但是它会唤醒在此对象监视器上等待的所有线程。

synchronized (this) {
    // 执行某些操作
    notifyAll(); // 唤醒所有等待线程
}

注意事项

  • 使用wait()、notify()和notifyAll()方法时，必须确保当前线程已经获得了对象的锁。
  • 在使用wait()方法时，应该放在一个循环中，以避免死锁。

回调机制

回调机制是一种常见的多线程编程模式，它允许一个线程在完成某项任务后通知另一个线程。

Java中的回调

在Java中，可以通过接口来实现回调机制。以下是一个简单的回调接口示例：

public interface Callback {
    void onCompleted();
}

使用回调

当任务完成时，可以通过调用回调接口的onCompleted()方法来通知另一个线程。

public class Task implements Runnable {
    private Callback callback;

    public Task(Callback callback) {
        this.callback = callback;
    }

    @Override
    public void run() {
        // 执行任务
        // ...
        // 任务完成后，调用回调
        callback.onCompleted();
    }
}

异步回调

在Java中，可以使用CompletableFuture来实现异步回调。

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
    // 异步执行任务
    // ...
});

future.thenRun(() -> {
    // 任务完成后执行的回调
});

实战案例

下面是一个使用等待与通知机制来同步两个线程的示例：

class Counter {
    private int count = 0;

    public synchronized void increment() {
        count++;
        System.out.println("Counter incremented to " + count);
        notify(); // 通知等待的线程
    }

    public synchronized int getCount() {
        while (count == 0) {
            try {
                wait(); // 等待直到计数不为0
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        return count;
    }
}

在这个例子中，increment()方法增加计数器的值，并在增加后唤醒等待的线程。getCount()方法等待直到计数器不为0。

通过掌握等待与回调机制，您可以在Java多线程编程中实现高效的任务处理。这些技术不仅可以提高应用程序的性能，还可以使代码更加清晰和易于管理。希望这篇文章能帮助您更好地理解和应用这些概念。