Hi3861 OpenHarmony嵌入式应用入门--LiteOS Thread_hi3861工具链

目录

Thread API

主要接口说明

测试代码编写

代码分析

hi3861使用的实时系统主要是基于Huawei LiteOS-M，这是华为针对物联网领域推出的轻量级物联网操作系统内核。LiteOS-M是Huawei LiteOS的一个分支，专为IoT领域构建，主要面向没有MMU（内存管理单元）的处理器。它具备轻量级、低功耗、组件丰富、快速开发等关键能力，为开发者提供“一站式”完整软件平台。

技术特点：

轻量级：LiteOS-M内核小巧，适合在资源受限的设备上运行。

低功耗：针对IoT设备的特点，LiteOS-M优化了功耗管理，使设备在运行时更省电。

快速开发：提供丰富的组件和API，降低开发门槛，缩短开发周期。

LiteOS-M通过优化任务调度和中断处理，保证了系统的实时响应能力。

结合hi3861的硬件性能，LiteOS-M能够确保在IoT设备中快速响应各种事件和数据变化。

Thread API

主要接口说明

osThreadId_t osThreadNew(osThreadFunc_t func, void *argument,const osThreadAttr_t *attr )

注意 :不能在中断服务调用该函数

参数：

osStatus_t osThreadTerminate (osThreadId_t thread_id)

测试代码编写

修改D:\DevEcoProjects\test\src\vendor\rtplay\rt_hi3861\demo\BUILD.gn文件

# Copyright (c) 2023 Beijing HuaQing YuanJian Education Technology Co., Ltd
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
# 
#    http://www.apache.org/licenses/LICENSE-2.0
# 
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License. 
 
import("//build/lite/config/component/lite_component.gni")
 
lite_component("demo") {
  features = [
    #"base_00_helloworld:base_helloworld_example",
    #"base_01_led:base_led_example",
    #"base_02_loopkey:base_loopkey_example",
    #"base_03_irqkey:base_irqkey_example",
    #"base_04_adc:base_adc_example",
    #"base_05_pwm:base_pwm_example",
    #"base_06_ssd1306:base_ssd1306_example",
    "kernel_01_task:kernel_task_example",
  ]
}

创建D:\DevEcoProjects\test\src\vendor\rtplay\rt_hi3861\demo\kernel_01_task文件夹

文件夹中创建D:\DevEcoProjects\test\src\vendor\rtplay\rt_hi3861\demo\kernel_01_task\kernel_task_example.c文件D:\DevEcoProjects\test\src\vendor\rtplay\rt_hi3861\demo\kernel_01_task\BUILD.gn文件

# Copyright (c) 2023 Beijing HuaQing YuanJian Education Technology Co., Ltd
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License. 
 
static_library("kernel_task_example") {
    sources = [
        "kernel_task_example.c",
    ]
 
    include_dirs = [
        "//utils/native/lite/include",
        "//kernel/liteos_m/kal/cmsis",
        "//base/iot_hardware/peripheral/interfaces/kits",
        "//vendor/hqyj/fs_hi3861/common/bsp/include"
    ]
}

/*
 * Copyright (C) 2023 HiHope Open Source Organization .
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#include <stdio.h>
#include <unistd.h>
 
#include "ohos_init.h"
#include "cmsis_os2.h"
 
#define THREAD_NUM (1000)
#define STACK_SIZE (1024)
#define DELAY_TICKS_20   (20)
#define DELAY_TICKS_100 (100)
 
osThreadId_t newThread(char *name, osThreadFunc_t func, char *arg)
{
    osThreadAttr_t attr = {
        name, 0, NULL, 0, NULL, STACK_SIZE*2, osPriorityNormal, 0, 0
    };
    osThreadId_t tid = osThreadNew(func, (void *)arg, &attr);
    if (tid == NULL) {
        printf("[Thread Test] osThreadNew(%s) failed.\r\n", name);
    } else {
        printf("[Thread Test] osThreadNew(%s) success, thread id: %d.\r\n", name, tid);
    }
    return tid;
}
 
void threadTest(char *arg)
{
    static int count = 0;
    printf("%s\r\n", arg);
    osThreadId_t tid = osThreadGetId();
    printf("[Thread Test] threadTest osThreadGetId, thread id:%p\r\n", tid);
    while (count < THREAD_NUM) {
        count++;
        printf("[Thread Test] threadTest, count: %d.\r\n", count);
        osDelay(DELAY_TICKS_20);
    }
}
 
void rtosv2_thread_main(void)
{
    osThreadId_t tid = newThread("test_thread", threadTest, "This is a test thread.");
 
    const char *t_name = osThreadGetName(tid);
    printf("[Thread Test] osThreadGetName, thread name: %s.\r\n", t_name);
 
    osThreadState_t state = osThreadGetState(tid);
    printf("[Thread Test] osThreadGetState, state :%d.\r\n", state);
 
    osStatus_t status = osThreadSetPriority(tid, osPriorityNormal4);
    printf("[Thread Test] osThreadSetPriority, status: %d.\r\n", status);
 
    osPriority_t pri = osThreadGetPriority(tid);
    printf("[Thread Test] osThreadGetPriority, priority: %d.\r\n", pri);
 
    status = osThreadSuspend(tid);
    printf("[Thread Test] osThreadSuspend, status: %d.\r\n", status);
 
    status = osThreadResume(tid);
    printf("[Thread Test] osThreadResume, status: %d.\r\n", status);
 
    uint32_t stacksize = osThreadGetStackSize(tid);
    printf("[Thread Test] osThreadGetStackSize, stacksize: %u.\r\n", stacksize);
 
    uint32_t stackspace = osThreadGetStackSpace(tid);
    printf("[Thread Test] osThreadGetStackSpace, stackspace: %u.\r\n", stackspace);
 
    uint32_t t_count = osThreadGetCount();
    printf("[Thread Test] osThreadGetCount, count: %u.\r\n", t_count);
 
    osDelay(DELAY_TICKS_100);
    status = osThreadTerminate(tid);
    printf("[Thread Test] osThreadTerminate, status: %d.\r\n", status);
}
 
static void ThreadTestTask(void)
{
    osThreadAttr_t attr;
 
    attr.name = "rtosv2_thread_main";
    attr.attr_bits = 0U;
    attr.cb_mem = NULL;
    attr.cb_size = 0U;
    attr.stack_mem = NULL;
    attr.stack_size = STACK_SIZE;
    attr.priority = osPriorityNormal;
 
    if (osThreadNew((osThreadFunc_t)rtosv2_thread_main, NULL, &attr) == NULL) {
        printf("[ThreadTestTask] Falied to create rtosv2_thread_main!\n");
    }
}
APP_FEATURE_INIT(ThreadTestTask);

代码分析

创建线程，创建成功则打印线程名字和线程ID

osThreadId_t newThread(char *name, osThreadFunc_t func, char *arg)
{
    // 定义线程属性结构体
    osThreadAttr_t attr = {
        name, 0, NULL, 0, NULL, STACK_SIZE*2, osPriorityNormal, 0, 0
    };
    // 创建线程，并传入参数
    osThreadId_t tid = osThreadNew(func, (void *)arg, &attr);
    if (tid == NULL) {
        // 如果创建失败，输出提示信息
        printf("[Thread Test] osThreadNew(%s) failed.\r\n", name);
    } else {
        // 如果创建成功，输出提示信息
        printf("[Thread Test] osThreadNew(%s) success, thread id: %d.\r\n", name, tid);
    }
    return tid;
}

该函数首先会打印自己的参数，然后对全局变量count进行循环+1操作，之后会打印count的值

void threadTest(char *arg)
{
    // 定义静态变量count，用于记录线程执行次数
    static int count = 0;
    // 打印传入参数
    printf("%s\r\n", arg);
    // 获取当前线程ID
    osThreadId_t tid = osThreadGetId();
    // 打印当前线程ID
    printf("[Thread Test] threadTest osThreadGetId, thread id:%p\r\n", tid);
    // 当count小于THREAD_NUM时，循环执行
    while (count < THREAD_NUM) {
        // count加1
        count++;
        // 打印count值
        printf("[Thread Test] threadTest, count: %d.\r\n", count);
        // 延时20个节拍
        osDelay(DELAY_TICKS_20);
    }
}

主程序rtosv2_thread_main创建线程并运行，并使用上述API进行相关操作，最后终止所创建的线程。

void rtosv2_thread_main(void)
{
    // 创建一个新的线程
    osThreadId_t tid = newThread("test_thread", threadTest, "This is a test thread.");
 
    // 获取线程名称
    const char *t_name = osThreadGetName(tid);
    printf("[Thread Test] osThreadGetName, thread name: %s.\r\n", t_name);
 
    // 获取线程状态
    osThreadState_t state = osThreadGetState(tid);
    printf("[Thread Test] osThreadGetState, state :%d.\r\n", state);
 
    // 设置线程优先级
    osStatus_t status = osThreadSetPriority(tid, osPriorityNormal4);
    printf("[Thread Test] osThreadSetPriority, status: %d.\r\n", status);
 
    // 获取线程优先级
    osPriority_t pri = osThreadGetPriority(tid);
    printf("[Thread Test] osThreadGetPriority, priority: %d.\r\n", pri);
 
    // 暂停线程
    status = osThreadSuspend(tid);
    printf("[Thread Test] osThreadSuspend, status: %d.\r\n", status);
 
    // 恢复线程
    status = osThreadResume(tid);
    printf("[Thread Test] osThreadResume, status: %d.\r\n", status);
 
    // 获取线程栈大小
    uint32_t stacksize = osThreadGetStackSize(tid);
    printf("[Thread Test] osThreadGetStackSize, stacksize: %u.\r\n", stacksize);
 
    // 获取线程栈空间
    uint32_t stackspace = osThreadGetStackSpace(tid);
    printf("[Thread Test] osThreadGetStackSpace, stackspace: %u.\r\n", stackspace);
 
    // 获取活跃线程数
    uint32_t t_count = osThreadGetCount();
    printf("[Thread Test] osThreadGetCount, count: %u.\r\n", t_count);
 
    // 延时100个时钟周期
    osDelay(DELAY_TICKS_100);
    // 终止线程
    status = osThreadTerminate(tid);
    printf("[Thread Test] osThreadTerminate, status: %d.\r\n", status);
}

使用build，编译成功后，使用upload进行烧录。