From 5a4e72d9024e39b6ae6023a71ef00f8c6906be40 Mon Sep 17 00:00:00 2001 From: nlevitt Date: Mon, 12 Sep 2011 22:49:32 +0000 Subject: [PATCH] Couple of synchronizations for HER-1943 WorkQueue: inconsistent synchronization using fields active, lastCost, peekItem, wakeTime * WorkQueue.java considerActive(), unpeek() - make synchronized --- .../src/main/java/org/archive/crawler/frontier/WorkQueue.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/engine/src/main/java/org/archive/crawler/frontier/WorkQueue.java b/engine/src/main/java/org/archive/crawler/frontier/WorkQueue.java index cc9c8fc7..3e8259f1 100644 --- a/engine/src/main/java/org/archive/crawler/frontier/WorkQueue.java +++ b/engine/src/main/java/org/archive/crawler/frontier/WorkQueue.java @@ -229,7 +229,7 @@ public abstract class WorkQueue implements Frontier.FrontierGroup, * URI for crawling, and continues until it is deactivated (for example, * for session-budget reasons). */ - public void considerActive() { + public synchronized void considerActive() { if(active) { return; } @@ -336,7 +336,7 @@ public abstract class WorkQueue implements Frontier.FrontierGroup, * return a different item. * */ - public void unpeek(CrawlURI expected) { + public synchronized void unpeek(CrawlURI expected) { assert expected == peekItem : "unexpected peekItem"; peekItem = null; }