- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在努力实现这一点:创建了两个不同的线程,一个打印奇数,一个打印偶数。一旦一个线程打印了一个数字,它就必须等待另一个线程等等,这是一个接一个的。
为了实现这一点,我将同步块(synchronized block)与 wait() 和 notify() 一起使用。
我正在创建一个类,其对象将用于传递给两个线程中的同步块(synchronized block)。
--> 这是将传递给同步块(synchronized block)的已用对象。
package com.vipin.multithread.variousdemos;
public class SyncObject {
public SyncObject () {
}
}
package com.vipin.multithread.variousdemos;
public class OddThread implements Runnable {
private Thread t;
int index=0;
SyncObject so=null;
int odd_nums[] = {1,3,5,7,9};
public OddThread(SyncObject so) {
t = new Thread(this,"Odd Thread");
this.so = so;
t.start();
}
public Thread getThreadInstance() {
return t;
}
@Override
public void run() {
while (true) {
synchronized(so) {
System.out.println("Odd num is --->" + odd_nums[index]);
try {
so.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
index++;
so.notify();
if(index>=5) {
return;
}
}
}
}
}
package com.vipin.multithread.variousdemos;
public class EvenThread implements Runnable {
private Thread t;
int index=0;
SyncObject so=null;
int even_nums[] = {2,4,6,8,10};
public EvenThread(SyncObject so) {
t = new Thread(this, "Even thread");
this.so = so;
t.start();
}
public Thread getThreadInstance() {
return t;
}
@Override
public void run() {
while(true) {
synchronized(so) {
System.out.println("Even num is --->" + even_nums[index]);
so.notify(); <-- Here we are notifying.
try {
so.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
index++;
//so.notify(); <-- commented out.
if(index>=5) {
break;
}
}
}
}
}
package com.vipin.multithread.variousdemos;
public class EvenOddDemo {
public static void main(String[] args) throws InterruptedException {
SyncObject so = new SyncObject();
OddThread ot = new OddThread(so);
EvenThread et = new EvenThread(so);
System.out.println("\nIn main thread");
Thread.sleep(1000000000);
System.out.println("Exiting main thread...");
}
}
---> 如代码所示,我正在创建两个线程来打印偶数和奇数。我正在使用同步块(synchronized block),并传递 ==> SyncObject 类型的对象。
我将 SyncObject 作为参数传递给 main 中的这些不同线程。
但是,这个程序会停止,即只执行第一个语句,然后永远等待:
奇数是--->1
在主线程中偶数是 --->2
我无法理解为什么这个程序会一直等待,我正在使用我们正在调用 synchronized()、wait() 和 notify() 的 SAME 对象。根据我的理解,它应该可以工作,但不确定为什么这不起作用。
关于为什么要永远等待的任何线索。
我对代码做了一些更改,UPDATE,它工作正常。
我还是有些疑惑。 notify() 是否被线程调用,即使它没有锁定监视器,就像我更新代码后的情况一样。
事件顺序:
首先执行奇数线程,然后调用 wait() <-- 它释放监视器,现在处于 sleep 模式。
甚至线程运行、打印消息和调用 notify() <-- 这里我没有清楚地理解。
当Even线程调用notify()时,此时它有管程,那么当它调用notify()时,它是否仍然拥有管程?
现在,在 Even 线程调用 notify() 之后,Odd 线程会收到通知,因此它会从 hibernate 点开始执行。它正在执行一些操作并调用 notify(),此时我认为奇数线程不拥有监视器,它调用 notify()。所以,我的问题是,无论线程是否拥有监视器,notify() 的工作方式是否相同?
只有自己写代码的时候,才真正明白这一点。看了书,觉得自己什么都懂了,好像又回到原点了!
最佳答案
这里的问题很简单,就是两个线程都直接进入等待状态。线程 1 获取 so
,打印值然后等待。线程 2 然后获取 so
,打印值然后等待。所以他们都在 sleep ,因为没有人在那里通知他们。因此,一个简单的修复方法是在 so.wait()
之前执行 so.notify()
。那么他们就不会无限期地等待。
编辑
奇数线程启动、执行然后等待。然后甚至线程启动、执行、通知并等待。 Even thread 持有监视器上的锁,直到它进入等待状态。
当偶数线程调用通知时,奇数线程唤醒并轮询锁。一旦偶数线程进入等待状态(&释放锁),那么奇数线程就可以获得锁。
如果偶数线程没有调用notify,那么奇数线程会继续 hibernate 。偶数线程会去等待并释放锁。没有线程正在轮询或尝试获取锁,因此程序保持挂起状态。
documentation也提供了类似的解释。我希望这能消除你的疑虑。
关于java - 程序停止 : wait() and notify(),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30141414/
我正在尝试在我安装的 Laravel 5.1 中设置 Gulp。我已经运行然后命令 npm install正如 Laravel 文档中所指定的那样,效果很好。 但是,当我现在运行命令时 gulp我收到
我有两个扩展线程的类和一个等待/通知 class A extends Thread { int r = 20; public void run() { try {
我正在尝试在后台服务中启动通知,这也是位置监听器。我有一个功能: public Notification CreateNotification(){ Intent notificati
编辑:我将其范围缩小到 python 代码中 Notifier.notify('Something') 的问题。当 python 脚本从 launchd 启动时,这不会产生预期的行为。我的其他 pyt
我正在尝试使用 bootstrap-notify v3.1.3、typescript、aurelia 和 VS2015 在我的网站上显示警报。 我的 aurelia 组件是: //myAlert.ts
注:other question的标题不同,导致无法识别为匹配的。 系统.类 TCollection = class(TPersistent) protected procedure Notify
我正在将一个项目从 Sprockets 迁移到 Webpacker。 我似乎无法正确运行的最后一件事是通知。 我曾经能够做到:$.notify('Test') 但现在我得到了 Uncaught Typ
我在一个项目中有多个用户控件,其中一个从 XML 中检索项目,创建“ClassItem”类型的对象,并应通知其他用户控件有关这些项目的信息。 我为我的对象创建了一个类(所有项目都将具有的“模型”):
我以为我会理解 Java 中的并发概念,但现在有一件事打破了我的理解: 为什么我必须在同步块(synchronized block)中包含对 wait() 和 notify() 方法的调用? 假设我有
我正在开发 NodeJS/Electron/Angular 应用程序,我正在使用 node-notifier 模块。一切正常,但在我的通知消息底部有一个不合适的“toast”字符串。它仅在我使用“图标
我正在基于Sproutcore 1.9.1的Web应用程序上工作。要从服务器检索数据 发出一个SC.Request.getUrl()请求,该请求在除IE8之外的所有浏览器中都可以正常工作。 对于IE8
我试图写一个关于如何使用wait()和notify()的示例,但是似乎无法通知wait() public class Transfer { private int[] data; pr
我想使用QAudioInput从麦克风捕获声音,对其进行处理然后再播放。据我了解,我需要连接到notify信号和内部处理程序,以便用户使用readAll()函数来获取原始数据。但是问题是,此处理函数永
public class Signal2NoiseRatio { public ImagePlus SingleSNR(ImagePlus imagePlus) throws Interrup
为什么只有第一个任务退出后才调用dispatchGroup.notify? 下面的代码输出如下: 1) Did the other thing **2) Did all the things** 3)
假设线程 T1 正在等待进入同步块(synchronized block),线程 T2 在同步块(synchronized block)内 wait(),并且线程 T3 在同步块(synchroniz
我正在尝试仅使用等待/通知同步来实现合并排序。我知道更高级的结构,例如 Fork/Join、Executors。等等,但我需要在这里使用工作/通知。基于此https://courses.cs.wash
了解 notifyAll 让我对 notify 产生了一些疑问:在典型情况下,我们有多个线程正在等待对 methody notify 的调用。当这种情况发生时,其中一个线程(之前调用了 wait 方法
我正在使用 wait() 和 notify() 编写一个示例程序,但是当调用 notify() 时,会出现多个线程被唤醒而不是一个。 代码是: public class MyQueue { O
根据17.2.4. Interactions of Waits, Notification, and Interruption : Similarly, notifications cannot be
我是一名优秀的程序员,十分优秀!