1

我有一个带有 JTabbedpane 的面板，在每个选项卡中，您都可以设置参数来执行查询。当一个查询忙于从数据库中检索他的数据时，您已经可以打开一个新选项卡来设置新参数。为了避免数据库过载，一次只能执行一个查询。但是当您单击执行时，程序必须记住以正确的顺序执行哪些查询。在执行过程中会显示一个加载器图标，并且 GUI 可能不会被冻结，因为您可以单击一个停止按钮来停止执行。
我使用了一个 swingworker 来避免 GUI 在执行查询时阻塞，并且效果很好。但现在我想阻止下一个查询在前一个查询完成之前开始。在整个面板通用的模型中，我初始化了一个信号量：private final Semaphore semaphore = new Semaphore(1, true);

这是启动 swingworker 的代码（我添加了 println 命令来查看哪个启动、停止或完成）

private void doStoredQuery() {
        try {
            semaphore.acquire();
            System.out.println(queryName + "started");
            worker.execute();
        } catch (InterruptedException e) {
           throw new RuntimeException(e);
        }
    }

这是我的 swingworker（initializeWorker() 是从主类的构造函数中调用的）：

private SwingWorker<StoredQueryDataModel, Integer> initializeWorker() {
    worker = new SwingWorker<StoredQueryDataModel, Integer>() {
        @Override
        protected StoredQueryDataModel doInBackground() throws Exception {
            try {
                StoredQueryDataModel dataModel = null;
                publish(0);
                try {
                    dataModel = new StoredQueryDataModel(queryRunner, ldbName, queryName, params);
                } catch (S9SQLException e) {
                    // 
                } catch (Throwable e) {
                    showErrorMessage(e);
                }
                return dataModel;
            }
            finally {
                semaphore.release();
                System.out.println(queryName + "finished");
            }
        }

        @Override
        protected void process(List<Integer> chunks) {
            //ignore chunks, just reload loader icon
            panel.repaint();
        }

        @Override
        protected void done() {
            String error;
            try {
                result = get();
                error = null;
            } catch (Exception e) {
                error = e.getMessage();
            }

            if(result == null) {
                semaphore.release();
                System.out.println(queryName + " stopped");
            }

            if(error == null) {
                // process result
            }
            else {
                showErrorMessage(new Throwable(error));
            }
        }

    };
    return worker;
}

我尝试将获取和发布放在代码中的其他位置，但似乎没有任何效果。我是 Swingworker 中的机器人，而且 sempahores 很新……有人可以帮忙吗？

4

1 回答 1

0

我发现了问题：信号量必须是静态变量。在我的代码中，信号量与选项卡一样多，这导致它们同时运行而不是顺序运行。

于 2013-01-14T13:53:15.770 回答