HarmonyOS 鸿蒙Next native线程队列中调用平台ArkTS的网络库 无法调通

在ohos中，JavaScript函数通常只能在native插件的主线程里调用。如果native侧创建了其他线程，则不能从这些线程调用需要napi_env、napi_value或napi_ref的NAPI接口。当native侧有其他线程，并且需要根据这些线程的完成结果调用JavaScript函数时，这些线程必须与native侧的主线程进行通信，才能在主线程中调用JavaScript函数。

解决方案：使用线程安全函数。napi_threadsafe_function

// 指向napi_value js_cb
napi_ref cbObj = nullptr;
// 线程安全函数
napi_threadsafe_function tsfn;
// Native侧Value值
static int cValue;
// 回调

static void CallJs(napi_env env, napi_value js_cb, void * context, void * data)
{
    // 获取引用值
    napi_get_reference_value(env, cbObj, &js_cb);
    // 创建一个ArkTS number作为ArkTS function的入参。
    napi_value argv;
    napi_create_int32(env, cValue, &argv);
    napi_value result = nullptr;
    napi_call_function(env, nullptr, js_cb, 1, &argv, &result);
    napi_get_value_int32(env, result, &cValue);
}

// Native 主线程

static napi_value ThreadsTest(napi_env env, napi_callback_info info)
{
    OH_LOG_INFO(LOG_APP, "dwt CallJs 0");
    // 从ArkTS侧获取的参数的数量
    size_t argc = 1;
    napi_value js_cb, work_name;
    // 获取ArkTS参数
    napi_get_cb_info(env, info, &argc, &js_cb, nullptr, nullptr);
    // 指向napi_value js_cb 的 napi_ref cbObj
    napi_create_reference(env, js_cb, 1, &cbObj);
    // 通过UTF8编码的C字符串数据创建work_name
    napi_create_string_utf8(env, "Work Item", NAPI_AUTO_LENGTH, &work_name);
    // 创建线程安全函数
    napi_create_threadsafe_function(env, js_cb, NULL, work_name, 0, 1, NULL, NULL, NULL, CallJs, &tsfn);
    // 其他线程中调用线程安全函数
    std::thread t({
        // 可获取线程ID
        std::thread::id this_id = std::this_thread::get_id();
        napi_acquire_threadsafe_function(tsfn);
        napi_call_threadsafe_function(tsfn, NULL, napi_tsfn_blocking);
    });
    t.detach();
    return NULL;
}

static napi_value SetValue(napi_env env, napi_callback_info info) {
    // 从ArkTS侧获取的参数的数量
    size_t argc = 1;
    napi_value jsValue;
    // 获取ArkTS参数
    napi_get_cb_info(env, info, &argc, &jsValue, nullptr, nullptr);
    napi_get_value_int32(env, jsValue, &cValue);
    return NULL;
}

static napi_value GetValue(napi_env env, napi_callback_info info) {
    napi_value jsValue;
    napi_create_int32(env, cValue, &jsValue);
    return jsValue;
}

// index.d.ts
export const threadsTest: (func: object) => number;
export const setValue: (value: number) => number;
export const getValue: () => number;

// index.ets
import entry from ‘libentry.so’;
import hilog from ‘@ohos.hilog’;
@Entry
@Component
struct Index {
    @State value: number = 20;
    @State cnt: number = 10;
    build() {
        Row() {
            Column() {
                Text("value: " + this.value.toString())
                Button("setValue To Native")
                    .onClick(() => {
                        entry.setValue(this.value)
                    }).margin(10)
                Button("跨线程调用JS函数")
                    .onClick(() => {
                        entry.threadsTest((value: number) => {
                            value += 10
                            this.cnt += 20
                            hilog.info(0x0000, 'testTag', 'js callback value = ' + value + " , cnt = " + this.cnt);
                            return value
                        })
                    }).margin(10)
                Button("getValue From Native")
                    .onClick(() => {
                        this.value = entry.getValue()
                    }).margin(10)
            }
            .width('100%')
        }
        .height('100%')
    }
}

参考线程安全函数的实现