|
|
@ -88,6 +88,23 @@ public final class plasmaCrawlStacker {
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void close() {
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
this.log.logFine("Shutdown. Terminationg worker threads.");
|
|
|
|
|
|
|
|
if (this.theWorkerPool != null) this.theWorkerPool.close();
|
|
|
|
|
|
|
|
} catch (Exception e1) {
|
|
|
|
|
|
|
|
this.log.logSevere("Unable to shutdown all remaining stackCrawl threads", e1);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
this.log.logFine("Shutdown. Closing stackCrawl queue.");
|
|
|
|
|
|
|
|
if (this.queue != null) this.queue.close();
|
|
|
|
|
|
|
|
this.queue = null;
|
|
|
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
|
|
|
this.log.logSevere("DB could not be closed properly.", e);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public int size() {
|
|
|
|
public int size() {
|
|
|
|
return this.queue.size();
|
|
|
|
return this.queue.size();
|
|
|
|
}
|
|
|
|
}
|
|
|
|