Worker

Имя работника, указанное в Worker.start или по умолчанию "worker $id",

val name: String

Преобразовать работника в значение COpaquePointer, которое можно передать через указатель native void*. Может использоваться в качестве аргумента Worker.fromCPointer.

fun asCPointer(): COpaquePointer?

Планирует задачу для дальнейшего выполнения в работнике. Execute — это операция в две фазы:

fun <T1, T2> execute(
    mode: TransferMode, 
    producer: () -> T1, 
    job: (T1) -> T2
): Future<T2>

Планирует задачу для дальнейшего выполнения в работнике. Параметр operation должен быть либо замороженным, либо выполнение должно быть запланировано на текущего работника. В противном случае будет выброшено исключение IllegalStateException. При использовании -Xworker-exception-handling=use-hook, если работник был создан с errorReporting значением true, любые исключения, выходящие из operation, будут обработаны с помощью processUnhandledException.

fun executeAfter(
    afterMicroseconds: Long = 0, 
    operation: () -> Unit)

Останавливает выполнение текущего работника до тех пор, пока не прибудет новый запрос или не истечет время ожидания, указанное в timeoutMicroseconds. Если process равно true, элементы очереди ожиданий обрабатываются, включая отложенные запросы. Обратите внимание, что таким образом может быть обработано несколько запросов.

fun park(
    timeoutMicroseconds: Long, 
    process: Boolean = false
): Boolean

Обработать ожидающую(ие) задачу(и) в очереди этого работника. Обратите внимание, что задачи, запланированные с помощью executeAfter с ненулевым временем ожидания, не обрабатываются таким образом. Если запрос на завершение поступает во время обработки очереди через этот API, работник помечается как завершенный и выйдет из системы, как только текущий запрос будет завершен.

fun processQueue(): Boolean

Запрашивает завершение работы работника.

fun requestTermination(
    processScheduledJobs: Boolean = true
): Future<Unit>

Строковое представление работника.

fun toString(): String

Возвращает текущего работника. Контекст работника доступен в любом допустимом контексте Kotlin, но только фактический активный работник, созданный с помощью Worker.start, автоматически обрабатывает запросы на выполнение. В других ситуациях processQueue должен вызываться явно для обработки очереди запросов.

val current: Worker

Создает объект работника из указателя C.

fun fromCPointer(pointer: COpaquePointer?): Worker

Запускает новую планирующую примитив, например, поток, для приема новых задач через интерфейс execute. Обычно новый работник может потребоваться для передачи вычислений на другой ядро, для ввода-вывода может быть лучше использовать асинхронный ввод-вывод в сочетании с более легкими сопрограммами.

fun start(
    errorReporting: Boolean = true, 
    name: String? = null
): Worker