我有一个 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!");
}
}
最佳答案
你不会得到想要的效果。仅当所有参与者都使用同一把锁时,锁才有用。对于您的代码,您试图控制的一件事情将会有很多锁。相反,使用什么锁并不重要,只要它是同一个锁即可。
一种简单的方法是进行同步(this)
。但是,推荐的方法是:
private final Object lock = new Object();
//
void method(){
synchronized(lock){
// stuff
}
}
这样不相关的参与者就不会意外使用你的锁(不可否认,这段代码看起来很愚蠢,在我看来是 Java 的一个设计缺陷)。
但是,就您而言,您可以简单地执行以下操作:
volatile QueryResult latestValidResult;
然后就完成了。这是因为 QueryResult 实际上是不可变的(据我猜测),并且因为有多个读取器但只有一个写入器,所以您只需使最新的有效结果对其他线程可见。在这种情况下, volatile
就足够了,IMO更容易理解你想要做什么。
关于java - 我是否正确使用了同步块(synchronized block)?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25461226/