
多线程 wait 方法报错的根源
通过提供的代码示例,我们看到作者意图是使用 wait/notify 机制来实现三个线程交替打印字符 abc。然而,代码中存在一个错误会导致报出 illegalmonitorstateexception。
错误出在每次线程打印完成后,作者错误地使用了 current_thread 对象来修改当前打印线程标识,同时又试图唤醒其他线程。这造成了一个死锁,因为 current_thread 对象充当锁角色,但其内部数据却在锁释放之前被修改了。
因此,线程 a 在等待其他线程释放锁时,由于锁已被修改,导致无法唤醒,从而抛出了 illegalmonitorstateexception。
法语写作助手
法语助手旗下的AI智能写作平台,支持语法、拼写自动纠错,一键改写、润色你的法语作文。
31 查看详情
解决方案:引入额外的锁对象
为了解决这个问题,我们可以引入一个额外的锁对象,专门用于实现同步,而 current_thread 对象仅用于传递当前打印线程标识。下面给出修改后的代码:
public class Test { private static volatile String CURRENT_THREAD = "A"; private static final Object lock = new Object(); // 额外锁对象 public static void main(String[] args) { Thread t1 = new Thread(new PrintThreadName(), "A"); Thread t2 = new Thread(new PrintThreadName(), "B"); Thread t3 = new Thread(new PrintThreadName(), "C"); t1.start(); t2.start(); t3.start(); } static class PrintThreadName implements Runnable { @Override public void run() { for (int i = 0; i < 5; i++) { synchronized (lock) { while (!CURRENT_THREAD.equals(Thread.currentThread().getName())) { try { lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.print(CURRENT_THREAD); if (CURRENT_THREAD.equals("A")) { CURRENT_THREAD = "B"; } else if (CURRENT_THREAD.equals("B")) { CURRENT_THREAD = "C"; } else if (CURRENT_THREAD.equals("C")) { CURRENT_THREAD = "A"; } lock.notifyAll(); } } } }}
在这个修改后的代码中,我们使用 lock 对象实现同步,而 current_thread 对象仅用于传递当前打印线程标识,从而解决了锁修改问题和死锁的可能性。
以上就是多线程wait方法报错:为什么使用wait/notify机制交替打印ABC会抛出IllegalMonitorStateException?的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/384330.html
微信扫一扫
支付宝扫一扫