# Running or Stopping an Event Loop in an Asynchronous Thread Using Node-API Extensions ## **Scenario** When calling asynchronous ArkTS APIs in the ArkTS running environment, you can use **napi_run_event_loop** to run an event loop and use **napi_stop_event_loop** to stop an event loop. ## Example If asynchronous ArkTS APIs are called, you can use **napi_run_event_loop** to run the events in the asynchronous thread cyclically. The underlying asynchronous tasks in the event queue will be processed based on the event loop mode. Currently, Node-API provides two modes for running event loops: **napi_event_mode_nowait** and **napi_event_mode_default**. - If **napi_event_mode_nowait** is used, the current asynchronous thread will not be blocked while the system attempts to process a task in the underlying event queue. After the task is complete, the event loop stops. If there is no task in the event queue, the event loop stops immediately. - If **napi_event_mode_default** is used, the system blocks the current asynchronous thread and keeps trying to obtain tasks from the event queue and execute these tasks. If you do not want the current thread to be blocked, use **napi_stop_event_loop** to stop the event loop. ### Sample Code - Register the module. ```c++ // hello.cpp #include "napi/native_api.h" #include #include static napi_value ResolvedCallback(napi_env env, napi_callback_info info) { napi_stop_event_loop(env); return nullptr; } static napi_value RejectedCallback(napi_env env, napi_callback_info info) { napi_stop_event_loop(env); return nullptr; } static void *RunEventLoopFunc(void *arg) { // 1. Create an ArkTS instance. napi_env env; napi_status ret = napi_create_ark_runtime(&env); if (ret != napi_ok) { return nullptr; } // 2. Load the custom module. napi_value objectUtils; // 'com.example.myapplication' is the bundle name of the current application. ret = napi_load_module_with_info(env, "ets/pages/ObjectUtils", "com.example.myapplication/entry", &objectUtils); if (ret != napi_ok) { return nullptr; } // 3. Call the asynchronous SetTimeout API. napi_value setTimeout = nullptr; napi_value promise = nullptr; napi_get_named_property(env, objectUtils, "SetTimeout", &setTimeout); napi_call_function(env, objectUtils, setTimeout, 0, nullptr, &promise); napi_value theFunc = nullptr; if (napi_get_named_property(env, promise, "then", &theFunc) != napi_ok) { return nullptr; } napi_value resolvedCallback = nullptr; napi_value rejectedCallback = nullptr; napi_create_function(env, "resolvedCallback", NAPI_AUTO_LENGTH, ResolvedCallback, nullptr, &resolvedCallback); napi_create_function(env, "rejectedCallback", NAPI_AUTO_LENGTH, RejectedCallback, nullptr, &rejectedCallback); napi_value argv[2] = {resolvedCallback, rejectedCallback}; napi_call_function(env, promise, theFunc, 2, argv, nullptr); auto flag = reinterpret_cast(arg); if (*flag == true) { napi_run_event_loop(env, napi_event_mode_default); } else { // Process the tasks in the event queue without blocking the asynchronous API. napi_run_event_loop(env, napi_event_mode_nowait); } return nullptr; } static napi_value RunEventLoop(napi_env env, napi_callback_info info) { pthread_t tid; size_t argc = 1; napi_value argv[1] = { nullptr }; napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr); bool flag = false; napi_get_value_bool(env, argv[0], &flag); // Create an asynchronous thread. pthread_create(&tid, nullptr, RunEventLoopFunc, &flag); pthread_join(tid, nullptr); return nullptr; } // Register the module. EXTERN_C_START static napi_value Init(napi_env env, napi_value exports) { napi_property_descriptor desc[] = { { "runEventLoop", nullptr, RunEventLoop, nullptr, nullptr, nullptr, napi_default, nullptr } }; napi_define_properties(env, exports, sizeof(desc) / sizeof(desc[0]), desc); return exports; } EXTERN_C_END static napi_module nativeModule = { .nm_version = 1, .nm_flags = 0, .nm_filename = nullptr, .nm_register_func = Init, .nm_modname = "entry", .nm_priv = nullptr, .reserved = { 0 }, }; extern "C" __attribute__((constructor)) void RegisterEntryModule() { napi_module_register(&nativeModule); } ``` - Declare the APIs. ```ts // index.d.ts export const runEventLoop: (isDefault: boolean) => object; ``` - Configure the compile settings. 1. Configure the CMakeLists.txt file as follows: ``` // CMakeLists.txt # the minimum version of CMake. cmake_minimum_required(VERSION 3.4.1) project(myapplication) set(NATIVERENDER_ROOT_PATH ${CMAKE_CURRENT_SOURCE_DIR}) if(DEFINED PACKAGE_FIND_FILE) include(${PACKAGE_FIND_FILE}) endif() include_directories(${NATIVERENDER_ROOT_PATH} ${NATIVERENDER_ROOT_PATH}/include) add_library(entry SHARED hello.cpp) target_link_libraries(entry PUBLIC libace_napi.z.so) ``` 2. Add the following to the **build-profile.json5** file of the project. ```json { "buildOption" : { "arkOptions" : { "runtimeOnly" : { "sources": [ "./src/main/ets/pages/ObjectUtils.ets" ] } } } } ``` - ArkTS sample code ```ts // index.ets import testNapi from 'libentry.so' testNapi.runEventLoop(true); ``` ```ts // ets/pages/ObjectUtils.ets export function SetTimeout() : Promise { return new Promise((resolve) => { setTimeout(() => { console.info('set timer delay 1s'); // attempt to stop the event loop at napi terminal resolve(); }, 1000) }) } ```