Package com.helix.core.executor

Class VirtualThreadExecutorMetrics

java.lang.Object

com.helix.core.executor.ExecutorMetrics

com.helix.core.executor.VirtualThreadExecutorMetrics

public class VirtualThreadExecutorMetrics
extends ExecutorMetrics

Extended metrics tracking execution counts, timing, active virtual thread tasks, and timeouts.

Constructor Summary

Constructors

Constructor	Description
VirtualThreadExecutorMetrics()

Method Summary

Modifier and Type	Method	Description
long	getActiveTasks()	Returns the number of currently active virtual-thread tasks.
long	getTimedOutExecutions()	Returns the total count of executions that exceeded their deadline timeout.
void	recordTimeout(long durationNanos)	Records an execution that failed due to a deadline timeout.
void	taskFinished()	Decrements the count of currently executing tasks.
void	taskStarted()	Increments the count of currently executing tasks.

Methods inherited from class com.helix.core.executor.ExecutorMetrics

getAverageExecutionTimeNanos, getFailedExecutions, getSuccessfulExecutions, getTotalExecutions, getTotalExecutionTimeNanos, recordExecution

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

VirtualThreadExecutorMetrics

public VirtualThreadExecutorMetrics()

Method Details

recordTimeout

public void recordTimeout(long durationNanos)

Records an execution that failed due to a deadline timeout.

Parameters:

durationNanos - elapsed time before timeout

taskStarted

public void taskStarted()

Increments the count of currently executing tasks.

taskFinished

public void taskFinished()

Decrements the count of currently executing tasks.

getTimedOutExecutions

public long getTimedOutExecutions()

Returns the total count of executions that exceeded their deadline timeout.

Returns:

timeout count

getActiveTasks

public long getActiveTasks()

Returns the number of currently active virtual-thread tasks.

Returns:

active task count