java - 当等待 Vector 对象的线程大于 6 时，wait 和 notificationAll 机制无法按预期工作

Question

我的应用程序中有一个要求，其中“N”个产品可以与报价相关联。屏幕布局将有两个部分。顶部有一个包含报价相关信息的表格，底部用于容纳多种产品。我通过在底部放置 iframe 来实现此功能。单击按钮即可添加/删除产品(使用 JavaScript)。每个产品窗口中显示的内容将由相同的操作 (ProductLinesAction.java)、JSP (ProductLines.jsp) 和其他关联资源呈现。这里的要点是，每当屏幕上加载新的产品窗口时，就会创建该 Action 类的多个实例。我在加载窗口时没有任何问题，因为它只是准备要显示的表单。当要保存报价时，所有这些产品表单都将被提交，我合并的逻辑是 1 到 N-1 个操作实例将表单值放入 VO 中，该 VO 添加到 Vector 对象并保存在 session 中(以便其他操作实例可以从 session 中获取它并添加到它的顶部)。第 N 个操作实例旨在共同保存所有这些产品值。业务规则验证也在保存之前执行，因此第 N 个操作实例将提供错误，这些错误应该显示在每个产品窗口中。

为了确保所有其他操作实例也利用与其窗口对应的错误，我实现了 wait 和 notificationAll 机制，其中当尝试保存超过 6 个产品时，事情就会出错。代码如下。这段代码对于小于或等于 6 个的产品(我的意思是最多 6 个操作实例)来说效果很好。当加载并保存第七个产品时，第七个实例在 Debug模式下根本不可见或不可跟踪(实例在表单提交时未达到预期方法)。

任何人都可以阐明这里所犯的导致此问题的错误吗？

public String submitProducts()
        throws Exception {

    String resultValue = "";
    /* Algorithm: */
    // 1. Read the Vector object from Session.
    // 2. Check whether the size of the Vector matches the Total Product windows count.
    // 3. If yes, call the Save operation and remove the list from session.
    // 4. If not, copy the values from current Action instance to VO.
    // 5. Add to List object and place in session.

    synchronized (productVOsInVector) {
        productVOsInVector = getProductVOVectorFromSession();
        if (productVOsInVector == null) {
            productVOsInVector = new Vector <ProductVO>();
        }
        log.info("Window Number is " + activeWindowNumber + ". List size is " + productVOsInVector.size());
        if (productVOsInVector.size() == (prodWindowCount - 1)) {
            productVOsInVector = mapActionToVO(productVOsInVector);
            resultValue = saveOperation(productVOsInVector);
            if (resultValue.equalsIgnoreCase(SUCCESS)) {
                session.put("OperationStatus", SUCCESS);
            }
            session.remove("productVOMapData");
        }
        else {
            if (quoteSaveStatus) {
                quoteSaveStatus = false;
            }
            session.put("OperationStatus", "");
            productVOsInVector = mapActionToVO(productVOsInVector);
            session.put("productVOMapData", productVOsInVector);
        }
        waitForOperationStatus();
    }
    System.out.println("Came out of sync block");
    System.out.println("Action Instance" + activeWindowNumber + " is resuming.");
    // Code to display the Error messages
    return resultValue;
}

public void waitForOperationStatus() {

    String opStatus = getOperationStatusFromSession();
    synchronized (productVOsInVector) {
        if (!opStatus.equalsIgnoreCase(SUCCESS)) {
            try {
                System.out.println("Window # " + activeWindowNumber + " Waiting");
                productVOsInVector.wait();                  
            }
            catch (InterruptedException e) {
                e.printStackTrace();
            }
            opStatus = getOperationStatusFromSession();
        }
        productVOsInVector.notifyAll();
    }
}

Answer 1

以下问题本身就已经是一个严重的问题:

synchronized (productVOsInVector) {
    productVOsInVector = getProductVOVectorFromSession();
    if (productVOsInVector == null) {
        productVOsInVector = new Vector <ProductVO>();
    }
    ...
}

您正在同步 productVOsInVector 引用的对象，并立即将该引用指向另一个对象。因此，下一个线程将在与第一个线程不同的对象上同步。

然后你就在等待这个对象，并希望有人通知你。

我没有分析更多，但你有一个严重的设计问题。首先，您不应该在 servlet 容器的线程之间进行同步。如果池中只有 6 个线程，并且它们都在等待第 7 个线程完成，则会出现死锁。如果池中有 12 个线程，并且有 2 个客户端同时执行此操作，也会出现死锁。即使没有死锁，也会使多个线程不可用，除了等待之外什么也不做，希望后续的 HTTP 请求能够通知它们。如果由于某种原因最后一个请求没有出现(例如，用户终止了他的浏览器，则有 6 个线程永远被阻塞。

我的建议是:不要弄乱线程。寻找另一种方式。