-
- All Implemented Interfaces:
-
java.lang.Runnable,kotlin.Comparable
public final class IndexThread extends Thread implements Comparable<IndexThread>
This class picks items from queues and fetches the pages.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classIndexThread.Companion
-
Field Summary
Fields Modifier and Type Field Description private final BooleanisHaltedprivate final ThreadLocal.ThreadLocalMapthreadLocalsprivate final ThreadLocal.ThreadLocalMapinheritableThreadLocalsprivate final ObjectparkBlockerprivate final LongthreadLocalRandomSeedprivate final IntegerthreadLocalRandomProbeprivate final IntegerthreadLocalRandomSecondarySeed
-
Constructor Summary
Constructors Constructor Description IndexThread(JITIndexer jitIndexer, ImmutableConfig conf)
-
Method Summary
Modifier and Type Method Description final BooleangetIsHalted()final Unithalt()final UnitexitAndJoin()Unitrun()IntegercompareTo(IndexThread other)-
Methods inherited from class ai.platon.pulsar.crawl.index.jit.indexer.IndexThread
checkAccess, clone, countStackFrames, getContextClassLoader, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, interrupt, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start, stop, suspend, toString -
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
IndexThread
IndexThread(JITIndexer jitIndexer, ImmutableConfig conf)
-
-
Method Detail
-
getIsHalted
final Boolean getIsHalted()
-
halt
final Unit halt()
-
exitAndJoin
final Unit exitAndJoin()
-
run
Unit run()
-
compareTo
Integer compareTo(IndexThread other)
-
-
-
-