java - 我是否正确使用了同步块(synchronized block)？

Question

我有一个 SwingWorker，它调用 twitter API 并获取一些结果，每次收到结果时，我首先更新成员变量 _latestValidResult，然后从结果中获取推文列表并将其添加到我的列表中，然后我发布该列表的大小。然后在发布中我需要使用 _latestValidResult 来访问一些 API 计时器限制，以便我可以更新我的 GUI。

我在更新 _latestValidResult 的 doInBackground() 和使用 _latestValidResult 的 process() 中有一个同步块(synchronized block) 获取计时器限制。

我询问是否正确使用了同步块(synchronized block)，因为我从 IDE 收到警告，提示我正在同步非最终变量。

这是带有一些伪代码的准系统代码，因此不会让您头疼:

public class ProduceStatusWorker extends SwingWorker<Void, Integer> {

    private QueryResult _latestValidResult;

    @Override
    protected Void doInBackground() {
        QueryResult result = null;
        Set<Status> allStatuses = new HashSet<>();
        do {
            try {
                if (isCancelled()) {
                    return null;
                }

                result = making_api_call_here;

                // If the call succeeded (no exception) then copy the result to the _latestValidResult
                synchronized (_latestValidResult) {
                    _latestValidResult = result;
                }

                allStatuses.addAll(result.getTweets());

                publish(allStatuses.size());

            } catch (TwitterException te) {
                // Handle exceptions here
            }

        } while (more_statuses_can_be_retrieved);

        return null;
    }

    @Override
    protected void process(List<Integer> chunks) {
        final int apiCallsTotal;
        final int apiCallsLeft;

        // Get the variables I need from _latestValidResult
        synchronized (_latestValidResult) {
            apiCallsTotal = _latestValidResult.getRateLimitStatus().getLimit();
            apiCallsLeft = _latestValidResult.getRateLimitStatus().getRemaining();
        }

        // Update GUI according to the variables
        jAPICallsLeftLabel.setText(Integer.toString(apiCallsLeft) + "/" + Integer.toString(apiCallsTotal));

        // Update GUI according to the publish
        jTweetsInMemory.setText(Integer.toString(chunks.get(chunks.size() - 1)));
    }
}

以下是 ProduceStatusWorker 类的完整代码:

public class ProduceStatusWorker extends SwingWorker<Void, Integer> {

    private final Query _query;

    private QueryResult _latestValidResult;

    private static final int QUERY_MAX_COUNT = 100;

    public ProduceStatusWorker(Query query) {
        _query = query;
        _query.setLang("en");
        _query.setResultType(ResultType.recent);
        _query.setCount(QUERY_MAX_COUNT);
    }

    @Override
    protected Void doInBackground() {
        QueryResult result = null;
        Set<Status> allStatuses = new HashSet<>();
        long lastID = Long.MAX_VALUE;
        do {
            try {
                while (timerIsRunning(_countdown) && !isCancelled()) {
                    try {
                        synchronized (this) {
                            wait(1000);
                        }
                    } catch (InterruptedException ex) {
                    }
                }

                if (isCancelled()) {
                    return null;
                }

                result = DbTools.TWITTER_FACTORY.search(_query);

                synchronized (_latestValidResult) {
                    _latestValidResult = result;
                }

                allStatuses.addAll(result.getTweets());

                for (Status status : result.getTweets()) {
                    if (status.getId() < lastID) {
                        lastID = status.getId();
                    }
                }
                publish(allStatuses.size());
                _query.setMaxId(lastID - 1);

            } catch (TwitterException te) {
                if (te.getErrorCode() == 88) {
                    if (!timerIsRunning(_countdown)) {
                        _countdown = new Timer(1000, new ActionListener() {
                            private int _count = _latestValidResult != null
                                    ? _latestValidResult.getRateLimitStatus().getSecondsUntilReset() : 10;

                            @Override
                            public void actionPerformed(ActionEvent e) {
                                if (_count == 0) {
                                    synchronized (ProduceStatusWorker.this) {
                                        ProduceStatusWorker.this.notifyAll();
                                    }
                                    jTimeLeftLabel.setText(DurationFormatUtils.formatDuration(_count-- * 1000, "mm:ss"));
                                    ((Timer) e.getSource()).stop();
                                } else {
                                    jTimeLeftLabel.setText(DurationFormatUtils.formatDuration(_count-- * 1000, "mm:ss"));
                                }
                            }
                        });
                        _countdown.start();
                    }

                } else {
                    cancel(true);
                    Printer.showError(te);
                }
            }

        } while ((_countdown != null && _countdown.isRunning()) || result.getTweets().size() > 0);

        return null;
    }

    @Override
    protected void process(List<Integer> chunks) {
        final int apiCallsTotal;
        final int apiCallsLeft;

        synchronized (_latestValidResult) {
            apiCallsTotal = _latestValidResult.getRateLimitStatus().getLimit();
            apiCallsLeft = _latestValidResult.getRateLimitStatus().getRemaining();
        }

        jAPICallsLeftLabel.setText(Integer.toString(apiCallsLeft) + "/" + Integer.toString(apiCallsTotal));
        jTweetsInMemory.setText(Integer.toString(chunks.get(chunks.size() - 1)));
    }

    @Override
    protected void done() {
        jStart.setSelected(false);
        JOptionPane.showMessageDialog(null, "Done!");
    }
}

Answer 1

你不会得到想要的效果。仅当所有参与者都使用同一把锁时，锁才有用。对于您的代码，您试图控制的一件事情将会有很多锁。相反，使用什么锁并不重要，只要它是同一个锁即可。

一种简单的方法是进行同步(this)。但是，推荐的方法是:

private final Object lock = new Object();
//
void method(){
    synchronized(lock){
        // stuff
    }
}

这样不相关的参与者就不会意外使用你的锁(不可否认，这段代码看起来很愚蠢，在我看来是 Java 的一个设计缺陷)。

但是，就您而言，您可以简单地执行以下操作:

volatile QueryResult latestValidResult;

然后就完成了。这是因为 QueryResult 实际上是不可变的(据我猜测)，并且因为有多个读取器但只有一个写入器，所以您只需使最新的有效结果对其他线程可见。在这种情况下， volatile 就足够了，IMO更容易理解你想要做什么。