guava-utils/com.pambrose.common.concurrent/GenericExecutionThreadService

GenericExecutionThreadService

abstract class GenericExecutionThreadService : AbstractExecutionThreadService

Abstract base class that wraps Guava's AbstractExecutionThreadService with Kotlin Duration-based synchronous start and stop methods.

Constructors

GenericExecutionThreadService

constructor()

Properties

val isRunning: Boolean

Functions

fun addListener(listener: Service.Listener?, executor: Executor?)

fun awaitRunning()

fun awaitRunning(timeout: Duration?)

fun awaitRunning(timeout: Long, unit: TimeUnit?)

awaitTerminated

fun awaitTerminated()

fun awaitTerminated(timeout: Duration?)

fun awaitTerminated(timeout: Long, unit: TimeUnit?)

fun failureCause(): Throwable?

genericServiceListener

fun Service.genericServiceListener(logger: KLogger): GuavaDsl.ServiceListenerHelper

Creates a Service.Listener for this Service that logs all lifecycle transitions (starting, running, stopping, terminated, failed) using the provided logger.

@CanIgnoreReturnValue

fun startAsync(): Service?

fun startSync(timeout: Duration = 30.seconds)

Starts the service asynchronously and blocks until it is running or the timeout expires.

fun state(): Service.State?

@CanIgnoreReturnValue

fun stopAsync(): Service?

fun stopSync(timeout: Duration = 30.seconds)

Stops the service asynchronously and blocks until it has terminated or the timeout expires.