Java 线程同步中的notify()方法示例
简介
Object 类包含notify()方法的定义。该方法只会唤醒一个正在等待项目的线程，然后该线程开始运行。可以使用线程类的notify()方法唤醒单个线程。当多个线程正在等待通知时使用notify()方法，只有一个线程会真正收到通知，并迫使其他线程继续等待。
让我们讨论线程同步中的Javanotify()方法，以及它的用法和编程示例。我们将研究它如何改进线程同步和线程间通信。
Java中notify()方法的解释
"notify()"方法属于Java中的Object类，用于促进线程间通信和协调。当线程对某个对象调用notify()时，它会唤醒对同一对象调用wait()的等待线程之一。被唤醒的线程从等待状态变为可运行状态，它将尝试重新获取对象的监视器锁以继续执行。
我们必须知道，notify()方法不会挑选要唤醒的线程。被唤醒线程的选择取决于JVM的内部实现，并且可能因每个Java运行时环境而异。如果没有线程在对象上等待，notify()方法调用将不起作用。
使用notify()方法解决卖家和客户问题
这个特定的程序属于如何使用notify()方法解决卖家和客户问题。
示例
import java.util.LinkedList;
import java.util.Queue;
public class CustomerItems
{
private final Object lock = new Object();
private Queue<Integer> buffer = new LinkedList<>();
private final int capacity = 10;
public void produce() throws InterruptedException {
synchronized (lock) {
while (buffer.size() == capacity)
{
lock.wait();
}
int items = 1;
buffer.add(items);
System.out.println("Number of Sold items: " + items);
lock.notify();
}
}
public void consume() throws InterruptedException {
synchronized (lock) {
while (buffer.isEmpty()) {
lock.wait();
}
int ValueofConsumeditem = buffer.poll();
System.out.println("Number of Consumed items: " + ValueofConsumeditem);
lock.notify();
}
}
public static void main(String args [])
{
CustomerItems example = new CustomerItems();
Thread producerThread = new Thread(() -> {
try {
while (true) {
example.produce();
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
Thread consumerThread = new Thread(() -> {
try {
while (true) {
example.consume();
Thread.sleep(1500);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
producerThread.start();
consumerThread.start();
}
}
输出
Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1 Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1 Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1 Number of Consumed items: 1 Number of Sold items: 1
为此，我们首先在程序中导入了一些重要的包。
java.util.LinkedList; java.util.Queue;
之后，我们定义了名为 CustomerItems 的类。在该类中，我们创建了该特定类的对象并创建了一个链接列表。
private final Object lock = new Object(); private Queue<Integer> buffer = new LinkedList<>();
然后，我们声明了一个名为 capacity 的变量，它是 final 和整数类型，并为该特定整数分配了一些值。然后，我们调用了一个名为 produce () 的函数，该函数有一个中断执行并执行一些同步工作。
public void consumer() throws InterruptedException
如果缓冲区已满，用户必须等到缓冲区为空。如果缓冲区为空，则用户有权向此缓冲区输入一些值。现在我们只需打印用户保存在缓冲区中的已消耗值。
int ValueofConsumeditem = buffer.poll();
System.out.println("已消费商品数量:" + ValueofConsumeditem)
然后我们调用了 main() 函数，并在此函数中创建了名为 example 的对象。
CustomerItems example = new CustomerItems ();
现在我们创建了一个线程来做这个特定的工作。
ThreadproducerThread = new Thread(() ->
并调用函数example()。
example.produce(); Thread.sleep(1500);
现在我们分别启动了生产者线程和消费者线程。
producerThread.start(); consumerThread.start();
展示Java的notify()方法的使用
在这个特定的编程示例中，我们将看到notify()方法的另一种应用。
示例
public class BossThread
{
public static void main (String args [])
{
WorkerThread workerThread = new WorkerThread();
workerThread.start();
synchronized (workerThread) {
try {
// 仅显示消息
System.out.println("我们现在等待 WorkerThread 完成!!!");
// 我们为主线程调用 wait() 方法
workerThread.wait();
}
catch (InterruptedException e) {
e.printStackTrace();
}
// 由WorkerThread打印结果
System.out.println("Result is: " + workerThread.getResult());
}
}
}
class WorkerThread extends Thread
{
private int output;
@Override
public void run()
{
synchronized (this)
{
for (int mp = 0; mp < 20; mp++)
{
output += mp;
}
// 使用notify()唤醒等待的线程
notify();
}
}
public int getResult() {
return output;
}
}
输出
we now wait for the WorkerThread to finish!!! Result is: 190
在这个程序中，我们首先定义了一个名为BossThread的类，并在该类中调用了main()函数。在main()函数中，我们创建了一个线程并启动了该线程。
WorkerThread workerThread = new WorkerThread(); workerThread.start();
现在我们已经完成了一些同步工作，以系统的方式完成任务是非常重要的任务。
synchronized (workerThread) {
try {
// 仅显示消息
System.out.println("我们现在等待WorkerThread完成!!!");
最后，我们只是打印了 workerthread 的结果。
System.out.println("Result is: " + workerThread.getResult());
之后，我们定义了另一个名为 WorkerThread 的类，它扩展了类线程。
class WorkerThread extends Thread
在这个类中，我们声明了一个名为"output"的变量，它是 final 和整数类型。现在我们已经执行了 run () 方法，并在 run () 函数中完成了一些同步工作。现在我们使用了notify()来唤醒等待的线程，并调用另一个名为getResult()的函数来从该函数中获取所需的输出。
public int getResult() {
return output;
}
}
结论
在本文中，我们学习了很多有关线程同步的notify()方法的配置和应用。在线程部分，同步是最重要的主题。要正确学习同步策略，我们必须详细了解notify()以涵盖整个线程主题。
