2

我正在实现一个控制器类，它必须在处理相同类型数据的线程上应用锁。因此，在这种情况下，我构建了两个用于应用和释放锁的类。

现在我在重新锁定时收到 IllegalMonitorStateException 异常。我知道目前我在另一个线程的监视器中。

这是锁定机制：

ConcurrentHashMap<String, Thread> Map = new ConcurrentHashMap<String, Thread>();
    Set<Thread> threadSet = Thread.getAllStackTraces().keySet();
    final Object lock = new Object();
    for (Thread thread : threadSet) {
        StringBuffer sb = new StringBuffer(thread.getName().toString());
        if ((sb.length() == 22) && (sb.toString().matches("[0-9]+"))
                && (thread != Thread.currentThread())) {
            utiMap.put(thread.getName().toString(), thread);
        }
    }

    synchronized (lock) {
        if (utiMap.containsKey(key)) {
            try {
                lock.wait();
            } catch (InterruptedException e) {
                lock.notifyAll();
            }
        } 
    }

以下是锁释放逻辑。

ConcurrentHashMap<String, Thread> Map = new ConcurrentHashMap<String, Thread>();
    Set<Thread> threadSet = Thread.getAllStackTraces().keySet();
    Object lock = new Object();
    for (Thread thread : threadSet) {
        StringBuffer sb = new StringBuffer(thread.getName().toString());
        if ((sb.length() == 22) && (sb.toString().matches("[0-9]+"))
                && (thread != Thread.currentThread()) && thread.getState().name().equals("WAITING")) {
            utiMap.put(thread.getName().toString(), thread);
            System.out.println("I am in controller Release -- ");
            thread.resume();
        }
    }
4

1 回答 1

4

你的代码是......恐怕......完全错误。

但更糟糕的是，我怀疑您正在尝试做一些无法完成的事情。或者如果可以，那么不应该这样做，因为它不能安全地完成。

似乎您正试图让一个线程导致另一个线程停止运行一段时间......然后恢复。您正在尝试在没有受控线程的合作/参与的情况下执行此操作。（这是我能想到的唯一解释“必须在线程上应用锁定” ......以及您的代码正在执行的旋转。）

不幸的是，你不能在 Java 中安全地做到这一点。如果你打算这样做，你需要调用thread.suspend()一个线程对象来临时停止它，然后调用thread.resume()同一个线程对象让它继续。但是这两种方法很久以前就被弃用了，因为（显然）它们很容易死锁。

还有几点需要注意：

final Object lock = new Object();
...
synchronized(lock) { ....

那个代码是错误的。Java 原始锁通过synchronize在一个（共享）对象上具有多个线程来工作。但是您正在同步当前线程可以看到的锁实例。最终结果将是实际上根本没有同步和锁定。

lock.wait();

这会等待notify该lock对象的其他线程，但是...

  • 没有其他线程可以看到该lock对象，并且
  • 唯一被调用的其他地方lock.notify是在当前线程上......在你因中断而醒来之后。（但如果线程已经被唤醒，则通知事件将被简单地丢弃。）

建议：

  1. 不要尝试像那样暂停/恢复线程。如果您希望一个线程被“控制”，那么修改该线程以定期检查它是否应该暂停。

  2. 你真的，真的需要阅读 Java 并发，因为你尝试的解决方案是......坦率地说......垃圾。

于 2013-07-10T15:42:21.793 回答