Java中的线程间通信

线程间通信或协作就是允许同步线程彼此通信。

合作（线程间通信）是一种机制, 其中一个线程在其关键部分中暂停运行, 并允许另一个线程进入（或锁定）要执行的同一关键部分中。它是通过以下Object类的方法实现的：

• 等待()
• 通知()
• notifyAll()

1）wait()方法

使当前线程释放锁定, 并等待直到另一个线程为此对象调用notify()方法或notifyAll()方法, 或者经过了指定的时间。

当前线程必须拥有此对象的监视器, 因此只能从同步方法中调用它, 否则它将引发异常。

2）notify()方法

唤醒正在此对象的监视器上等待的单个线程。如果有任何线程在该对象上等待, 则选择其中一个唤醒。该选择是任意的, 并且可以根据实现情况进行选择。句法：

公共最终无效notify()

3）notifyAll()方法

唤醒正在此对象的监视器上等待的所有线程。句法：

公共最终无效notifyAll()

了解线程间通信的过程

上图的点对点解释如下：

1. 线程进入以获取锁。
2. 锁是通过线程获取的。
3. 现在, 如果你在对象上调用wait()方法, 线程将进入等待状态。否则, 它将释放锁定并退出。
4. 如果调用notify()或notifyAll()方法, 线程将移至已通知状态（可运行状态）。
5. 现在可以使用线程来获取锁。
6. 任务完成后, 线程释放锁定并退出对象的监视状态。

为什么在对象类而不是线程类中定义了wait(), notify()和notifyAll()方法？

这是因为它们与锁相关, 并且对象具有锁。

等待和睡眠之间的区别？

让我们看看等待和睡眠方法之间的重要区别。

Java中的线程间通信示例

让我们看一下线程间通信的简单示例。

class Customer{
int amount=10000;

synchronized void withdraw(int amount){
System.out.println("going to withdraw...");

if(this.amount<amount){
System.out.println("Less balance; waiting for deposit...");
try{wait();}catch(Exception e){}
}
this.amount-=amount;
System.out.println("withdraw completed...");
}

synchronized void deposit(int amount){
System.out.println("going to deposit...");
this.amount+=amount;
System.out.println("deposit completed... ");
notify();
}
}

class Test{
public static void main(String args[]){
final Customer c=new Customer();
new Thread(){
public void run(){c.withdraw(15000);}
}.start();
new Thread(){
public void run(){c.deposit(10000);}
}.start();

}}

Output: going to withdraw...
       Less balance; waiting for deposit...
       going to deposit...
       deposit completed...
       withdraw completed