public class SecondarySearchSuperviser
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
private java.util.SortedMap<java.lang.String,java.util.SortedMap<java.lang.String,java.util.Set<java.lang.String>>> |
abstractsCache |
private java.util.SortedSet<java.lang.String> |
checkedPeers |
private SearchEvent |
searchEvent |
private java.util.concurrent.Semaphore |
trigger |
Modifier | Constructor and Description |
---|---|
protected |
SecondarySearchSuperviser(SearchEvent searchEvent) |
Modifier and Type | Method and Description |
---|---|
void |
addAbstract(java.lang.String wordhash,
java.util.SortedMap<java.lang.String,java.util.Set<java.lang.String>> singleAbstract)
add a single abstract to the existing set of abstracts
|
void |
commitAbstract() |
private void |
prepareSecondarySearch() |
void |
run() |
private java.util.Set<java.lang.String> |
wordsFromPeer(java.lang.String peerhash,
java.util.Set<java.lang.String> urls) |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
private final java.util.SortedMap<java.lang.String,java.util.SortedMap<java.lang.String,java.util.Set<java.lang.String>>> abstractsCache
private final java.util.SortedSet<java.lang.String> checkedPeers
private final java.util.concurrent.Semaphore trigger
private final SearchEvent searchEvent
protected SecondarySearchSuperviser(SearchEvent searchEvent)
public void addAbstract(java.lang.String wordhash, java.util.SortedMap<java.lang.String,java.util.Set<java.lang.String>> singleAbstract)
wordhash
- singleAbstract
- // a mapping from url-hashes to a string of peer-hashespublic void commitAbstract()
private java.util.Set<java.lang.String> wordsFromPeer(java.lang.String peerhash, java.util.Set<java.lang.String> urls)
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
private void prepareSecondarySearch()