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)
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)

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