原生C++移动端跨线程调用：求类似runOnUIThread的主线程回调库

嘿，我完全懂你的痛点——不想写那些繁琐的消息队列轮询或者死循环查future状态的代码，就想找个能自动把耗时任务的结果投递回主线程的简洁方案对吧？下面给你几个符合需求的库和实现思路：

1. RxCpp（跨平台响应式编程库） #

RxCpp是C++的响应式扩展，完美适配Android/iOS移动端，它天生就是为异步任务+线程切换设计的，完全不需要你手动处理轮询或者循环：

• 你可以把耗时任务放到后台线程执行，然后通过observe_on指定主线程的调度器，结果会自动在主线程回调给你。
• 示例代码大概是这样的：

#include <rxcpp/rx.hpp>

// 主线程初始化时，获取主线程调度器（Android可通过JNI关联Looper，iOS绑定主队列）
auto main_thread_scheduler = rxcpp::schedulers::make_event_loop();

// 发起耗时任务
rxcpp::observable<>::create<int>([](rxcpp::subscriber<int> s) {
    // 后台线程执行的耗时操作
    int result = do_heavy_calculation();
    s.on_next(result);
    s.on_completed();
})
.subscribe_on(rxcpp::schedulers::new_thread()) // 指定耗时任务在新线程执行
.observe_on(main_thread_scheduler) // 指定结果在主线程处理
.subscribe([](int result) {
    // 这里就是主线程，直接处理结果，相当于自动调用了runOnUIThread
    update_user_interface(result);
});

• 优势：完全不用手动管理线程切换和结果传递，代码简洁，跨平台通用。

2. QtConcurrent（若项目基于Qt） #

如果你的移动端应用是用Qt开发的，QtConcurrent是官方提供的异步任务库，配合Qt的信号槽机制，可以轻松把结果抛回主线程：

• 用QtConcurrent::run执行耗时任务，然后通过QFutureWatcher监听结果，任务完成时Watcher会自动在主线程触发信号：

#include <QtConcurrent>
#include <QFutureWatcher>

// 耗时函数
int heavy_process_task() {
    return do_heavy_work();
}

// 在主线程调用这段代码
auto future = QtConcurrent::run(heavy_process_task);
QFutureWatcher<int>* watcher = new QFutureWatcher<int>;
connect(watcher, &QFutureWatcher<int>::finished, [=]() {
    int result = watcher->result();
    // 这里是主线程，直接更新UI
    refresh_ui_with_result(result);
    watcher->deleteLater();
});
watcher->setFuture(future);

• 本质上Qt已经帮你封装了底层的消息队列，但你完全不用写轮询代码，相当于自动帮你调用了类似runOnUIThread的逻辑。

3. Android NDK 封装Handler（平台专属） #

如果你的应用只针对Android平台，你可以基于NDK的ALooper和JNI封装一个极简的回调工具，完美模拟runOnUIThread的效果：

• 首先在Java层写一个工具类，提供runOnUiThread的接口：

// Java 工具类
public class UiThreadDispatcher {
    public static void runOnUiThread(Runnable runnable) {
        if (Looper.myLooper() == Looper.getMainLooper()) {
            runnable.run();
        } else {
            new Handler(Looper.getMainLooper()).post(runnable);
        }
    }
}

• 然后在C++层封装JNI调用，当耗时任务完成时，直接调用这个Java方法把结果传递回去：

#include <jni.h>

// 全局保存JNIEnv和类引用（注意线程安全，可通过AttachCurrentThread处理）
static JNIEnv* g_main_env;
static jclass g_dispatcher_cls;

// 初始化（在主线程调用）
void init_ui_dispatcher(JNIEnv* env) {
    g_main_env = env;
    jclass cls = env->FindClass("com/yourpackage/UiThreadDispatcher");
    g_dispatcher_cls = (jclass)env->NewGlobalRef(cls);
}

// 耗时任务完成后调用，把结果抛回主线程
void post_result_to_ui(int result) {
    // 获取runOnUiThread方法ID
    jmethodID mid = g_main_env->GetStaticMethodID(g_dispatcher_cls, "runOnUiThread", "(Ljava/lang/Runnable;)V");
    // 这里可以通过JNI创建Runnable对象，内部处理结果更新UI的逻辑
    // 简化示例中，假设你有Java方法接收int结果并更新UI，可直接传递参数
    // 核心逻辑是：通过JNI触发主线程的Runnable执行，完全避免轮询
    g_main_env->CallStaticVoidMethod(g_dispatcher_cls, mid, your_runnable);
}

• 这个方案虽然需要写一点JNI代码，但完全不需要轮询，后台任务完成后直接触发主线程的UI更新，和runOnUIThread的逻辑完全一致。

总结 #

如果想要跨平台、无轮询的简洁方案，RxCpp是最优选择；如果用Qt，QtConcurrent是官方标配；如果只针对Android，封装JNI+Handler的方案最轻量化，完全贴合你想要的“直接调用类似runOnUIThread返回结果”的需求。

内容的提问来源于stack exchange，提问作者Oktaheta