Class EventConsumerThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.maven.surefire.extensions.CloseableDaemonThread
-
- org.apache.maven.plugin.surefire.extensions.EventConsumerThread
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,java.lang.Runnable
,Stoppable
public class EventConsumerThread extends CloseableDaemonThread
-
-
Field Summary
Fields Modifier and Type Field Description private ForkNodeArguments
arguments
private java.nio.channels.ReadableByteChannel
channel
private CountdownCloseable
countdownCloseable
private EventDecoder
decoder
private boolean
disabled
private EventHandler<Event>
eventHandler
-
Constructor Summary
Constructors Constructor Description EventConsumerThread(java.lang.String threadName, java.nio.channels.ReadableByteChannel channel, EventHandler<Event> eventHandler, CountdownCloseable countdownCloseable, ForkNodeArguments arguments)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
disable()
void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
channel
private final java.nio.channels.ReadableByteChannel channel
-
eventHandler
private final EventHandler<Event> eventHandler
-
countdownCloseable
private final CountdownCloseable countdownCloseable
-
decoder
private final EventDecoder decoder
-
arguments
private final ForkNodeArguments arguments
-
disabled
private volatile boolean disabled
-
-
Constructor Detail
-
EventConsumerThread
public EventConsumerThread(@Nonnull java.lang.String threadName, @Nonnull java.nio.channels.ReadableByteChannel channel, @Nonnull EventHandler<Event> eventHandler, @Nonnull CountdownCloseable countdownCloseable, @Nonnull ForkNodeArguments arguments)
-
-