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

GenericIdleService

abstract class GenericIdleService : AbstractIdleService

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

Constructors

GenericIdleService

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(maxWait: Duration = 15.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(maxWait: Duration = 15.seconds)

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