HarmonyOS鸿蒙Next之线程02——EventHandler处理线程间通信

HarmonyOS鸿蒙Next之线程02——EventHandler处理线程间通信 创建一个名为EventHandler的Car设备类型的任务，用于演示EventHandler处理线程间通信的使用。

事件循环器

大家如果有开发Netty或者Node.js应用的话，那么对于事件循环器就不大陌生了，事件循环器是高并发非阻塞的“秘笈”。在HarmonyOS中，事件循环器实现方式就是EventHandler机制。当前线程中处理较为耗时的操作时，如果不希望当前的线程受到阻塞。此时，就可以使用EventHandler机制。EventHandler是HarmonyOS用于处理线程间通信的一种机制，可以通过EventRunner创建新线程，将耗时的操作放到新线程上执行。这样既不阻塞原来的线程，任务又可以得到合理的处理。比如：主线程使用EventHandler创建子线程，子线程做耗时的下载图片操作，下载完成后，子线程通过EventHandler通知主线程，主线程再更新UI。

Netty或者Node.js方面的内容，可以参见本文最后引用部分。

修改ability_main.xml

修改ability_main.xml内容如下：

<?xml version="1.0" encoding="utf-8"?>
<DirectionalLayout
    xmlns:ohos="http://schemas.huawei.com/res/ohos"
    ohos:height="match_parent"
    ohos:width="match_parent"
    ohos:orientation="vertical">

    <Text
        ohos:id="$+id:text_send_event"
        ohos:height="match_parent"
        ohos:width="match_content"
        ohos:background_element="$graphic:background_ability_main"
        ohos:layout_alignment="horizontal_center"
        ohos:text="Send Event"
        ohos:text_size="50" />
</DirectionalLayout>

显示界面效果如下图1所示

自定义事件处理器

MyEventHandler是自定义的一个事件处理。该事件处理器逻辑比较简单，只是模拟了一个耗时的操作。

package com.waylau.hmos.eventhandler;

import ohos.eventhandler.EventHandler;
import ohos.eventhandler.EventRunner;
import ohos.eventhandler.InnerEvent;
import ohos.hiviewdfx.HiLog;
import ohos.hiviewdfx.HiLogLabel;

import java.util.concurrent.TimeUnit;

public class MyEventHandler extends EventHandler {
    private static final String TAG = MyEventHandler.class.getSimpleName();
    private static final HiLogLabel LABEL_LOG =
        new HiLogLabel(HiLog.LOG_APP, 0x00001, TAG);

    public MyEventHandler(EventRunner runner) throws IllegalArgumentException {
        super(runner);
    }

    @Override
    public void processEvent(InnerEvent event) {
        super.processEvent(event);
        if (event == null) {
            HiLog.info(LABEL_LOG, "before processEvent event is null");
            return;
        }
        int eventId = event.eventId;
        HiLog.info(LABEL_LOG, "before processEvent eventId: %{public}s", eventId);

        int task1Result = getRandomInt();
        try {
            // 模拟一个耗时的操作
            TimeUnit.MILLISECONDS.sleep(task1Result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        HiLog.info(LABEL_LOG, "after processEvent eventId %{public}s", eventId);
    }

    // 返回随机整数
    private int getRandomInt() {
        // 获取[0, 1000)之间的int整数。方法如下：
        double a = Math.random();
        int result = (int) (a * 1000);
        return result;
    }
}

这个耗时操作，是通过获取一个随机数，而后根据随机数执行线程sleep实现的。

执行事件发送

修改MainAbilitySlice，增加事件发送相关的逻辑。

package com.waylau.hmos.eventhandler.slice;

import com.waylau.hmos.eventhandler.MyEventHandler;
import com.waylau.hmos.eventhandler.ResourceTable;
import ohos.aafwk.ability.AbilitySlice;
import ohos.aafwk.content.Intent;
import ohos.agp.components.Text;
import ohos.eventhandler.EventRunner;
import ohos.hiviewdfx.HiLog;
import ohos.hiviewdfx.HiLogLabel;

public class MainAbilitySlice extends AbilitySlice {
    private static final String TAG = MainAbilitySlice.class.getSimpleName();
    private static final HiLogLabel LABEL_LOG =
        new HiLogLabel(HiLog.LOG_APP, 0x00001, TAG);

    private EventRunner eventRunner = EventRunner.create("MyEventRunner"); // 内部会新建一个线程
    private int eventId = 0; // 事件ID，递增的序列

    @Override
    public void onStart(Intent intent) {
        super.onStart(intent);
        super.setUIContent(ResourceTable.Layout_ability_main);

        Text textSendEvent =
            (Text) findComponentById(ResourceTable.Id_text_send_event);
        textSendEvent.setClickedListener(listener -> sendEvent());
    }

    private void sendEvent() {
        HiLog.info(LABEL_LOG, "before sendEvent");

        MyEventHandler handler = new MyEventHandler(eventRunner);

        eventId++;
        handler.sendEvent(eventId);

        HiLog.info(LABEL_LOG, "end sendEvent eventId: %{public}s", eventId);
    }

    @Override
    public void onActive() {
        super.onActive();
    }

    @Override
    public void onForeground(Intent intent) {
        super.onForeground(intent);
    }
}

上述代码，

• Text增加了点击事件，以触发sendEvent任务
• sendEvent方法中创建了EventHandler事件处理器
• 通过EventHandler的sendEvent方法发送了一个事件ID。事件ID是自增的序列。

运行

运行应用后，点击3次界面文本“Start Event”以触发事件派发。此时，控制台输出如下：

01-15 14:47:05.056 3943-3943/com.waylau.hmos.eventhandler I 00001/MainAbilitySlice: before sendEvent
01-15 14:47:05.057 3943-3943/com.waylau.hmos.eventhandler I 00001/MainAbilitySlice: end sendEvent eventId: 1
01-15 14:47:05.058 3943-4024/com.waylau.hmos.eventhandler I 00001/MyEventHandler: before processEvent eventId: 1
01-15 14:47:05.196 3943-4024/com.waylau.hmos.eventhandler I 00001/MyEventHandler: after processEvent eventId 1

01-15 14:47:07.731 3943-3943/com.waylau.hmos.eventhandler I 00001/MainAbilitySlice: before sendEvent
01-15 14:47:07.732 3943-4024/com.waylau.hmos.eventhandler I 00001/MyEventHandler: before processEvent eventId: 2
01-15 14:47:07.732 3943-3943/com.waylau.hmos.eventhandler I 00001/MainAbilitySlice: end sendEvent eventId: 2
01-15 14:47:08.104 3943-4024/com.waylau.hmos.eventhandler I 00001/MyEventHandler: after processEvent eventId 2

01-15 14:47:09.149 3943-3943/com.waylau.hmos.eventhandler I 00001/MainAbilitySlice: before sendEvent
01-15 14:47:09.151 3943-3943/com.waylau.hmos.eventhandler I 00001/MainAbilitySlice: end sendEvent eventId: 3
01-15 14:47:09.159 3943-4024/com.waylau.hmos.eventhandler I 00001/MyEventHandler: before processEvent eventId: 3
01-15 14:47:09.300 3943-4024/com.waylau.hmos.eventhandler I 00001/MyEventHandler: after processEvent eventId 3

分别执行了3次可以看到MainAbilitySlice先是发送了事件，而后MyEventHandler就处理了事件。

参考引用

• 更多示例源码，见《跟老卫学HarmonyOS》 https://github.com/waylau/harmonyos-tutorial
• 《Netty原理解析与开发实战》 https://item.jd.com/13072504.html
• 《Node.js企业级应用开发实战》 https://item.jd.com/12924544.html