Class AsyncExecutor

java.lang.Object

org.apache.opendal.NativeObject

org.apache.opendal.AsyncExecutor

All Implemented Interfaces:

AutoCloseable

public class AsyncExecutor
extends NativeObject

AsyncExecutor represents an underneath OpenDAL executor that runs async tasks spawned in the Rust world.

If the executor is passed to construct operators, the executor must outlive the operators.

Worker threads use the class loader that defines OpenDAL as their context class loader. Completion callbacks that change it must restore it before returning.

Field Summary

Fields inherited from class NativeObject

nativeHandle

Method Summary

Modifier and Type	Method	Description
static AsyncExecutor	createTokioExecutor(int cores)	Create a Tokio executor with the specified number of worker threads.
protected void	disposeInternal(long handle)	Deletes underlying native object pointer.

Methods inherited from class NativeObject

close, isDisposed

Methods inherited from class Object

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

Method Details

createTokioExecutor

public static AsyncExecutor createTokioExecutor(int cores)

Create a Tokio executor with the specified number of worker threads.

Parameters:

cores - the number of worker threads; must be positive

Returns:

the executor

Throws:

IllegalArgumentException - if cores is zero or negative

disposeInternal

protected void disposeInternal(long handle)

Description copied from class: NativeObject

Deletes underlying native object pointer.

Specified by:

disposeInternal in class NativeObject

Parameters:

handle - to the native object pointer