15天rt-thread入门学习 - 第十三天（信号）

发布于 2018-05-30 09:29:57 浏览：2272 订阅该版

信号，主要包括：
1、信号的本质
   信号其实就是软中断，主要用于异步通信。
2、例程源码解读及信号相关操作介绍
   rt_signal_install -- 在任务中安装信号
   rt_signal_unmask  -- 关注信号（定义要监测的信号）
   rt_thread_kill    -- 发送信号
   在安装信号时已经指定了信号处理函数，所以没有接收信号API
3、信号丢失
   每个信号都是一个bit
   如果有多个任务向同一个任务发送信号，信号不会进行排队，则关注信号的任务不知道信号是哪个任务发送的，所以存在信号丢失现象。

作业：
1、创建两个任务，任务1运行中向任务2发送一个信号，任务2收到信号后退出任务的执行。
在示例程序基础上修改后的程序如下：
```#include <rtthread.h>

#define THREAD_PRIORITY         25
#define THREAD_STACK_SIZE       512
#define THREAD_TIMESLICE        5

static rt_thread_t tid1 = RT_NULL, tid2 = RT_NULL;

static uint8_t flag = 0;

/* 线程1的信号处理函数 */
void thread1_signal_handler(int sig)
{
    rt_kprintf("thread1 received signal %d<br>", sig);
}

/* 线程2的信号处理函数 */
void thread2_signal_handler(int sig)
{
    rt_kprintf("thread2 received signal %d<br>", sig);
    flag = 1;
}

/* 线程1的入口函数 */
static void thread1_entry(void *parameter)
{
    int cnt = 0;

/* 运行20次 */
    while (cnt < 20)
    {
        /* 线程1采用低优先级运行，一直打印计数值 */
        rt_kprintf("thread1 count : %d<br>", cnt);

cnt++;
        if(cnt == 10)
        {
            /* 发送信号 SIGUSR2 给线程2 */
            rt_thread_kill(tid2, SIGUSR2);
        }
        rt_thread_delay(10);
    }
}

/* 线程2的入口函数 */
static void thread2_entry(void *parameter)
{
    int cnt = 0;

/* 安装信号 */
    rt_signal_install(SIGUSR2, thread2_signal_handler);
    rt_signal_unmask(SIGUSR2);

/* 运行10次 */
    while (flag == 0)
    {
        rt_kprintf("thread2 count : %d<br>", cnt);

cnt++;
        rt_thread_delay(20);
    }
}

/* 信号示例的初始化 */
int signal_sample_init()
{
    /* 创建线程1 */
    tid1 = rt_thread_create("t1", /* 线程1的名称是t1 */
                            thread1_entry, RT_NULL,   /* 入口是thread1_entry，参数是RT_NULL */
                            THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);

if (tid1 != RT_NULL) /* 如果获得线程控制块，启动这个线程 */
        rt_thread_startup(tid1);

/* 创建线程2 */
    tid2 = rt_thread_create("t2", /* 线程2的名称是t2 */
                            thread2_entry, RT_NULL,   /* 入口是thread2_entry，参数是RT_NULL */
                            THREAD_STACK_SIZE, THREAD_PRIORITY - 1, THREAD_TIMESLICE);

if (tid2 != RT_NULL) /* 如果获得线程控制块，启动这个线程 */
        rt_thread_startup(tid2);

rt_thread_delay(500);

/* 发送信号 SIGUSR1 给线程1 */
    //rt_thread_kill(tid1, SIGUSR1);
    /* 发送信号 SIGUSR2 给线程2 */
    //rt_thread_kill(tid2, SIGUSR2);

return 0;
}
/* 如果设置了RT_SAMPLES_AUTORUN，则加入到初始化线程中自动运行 */
#if defined (RT_SAMPLES_AUTORUN) && defined(RT_USING_COMPONENTS_INIT)
    INIT_APP_EXPORT(signal_sample_init);
#endif
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(signal_sample_init, signal sample);```
运行结果：
``` \ | /
- RT -     Thread Operating System
 / | \     3.0.4 build May 30 2018
 2006 - 2018 Copyright by rt-thread team
msh >sig
signal_sample_init
msh >signal_sample_init
thread2 count : 0
thread1 count : 0
thread1 count : 1
thread2 count : 1
thread1 count : 2
thread1 count : 3
thread2 count : 2
thread1 count : 4
thread1 count : 5
thread2 count : 3
thread1 count : 6
thread1 count : 7
thread2 count : 4
thread1 count : 8
thread1 count : 9
thread2 received signal 11
thread1 count : 10
thread1 count : 11
thread1 count : 12
thread1 count : 13
thread1 count : 14
thread1 count : 15
thread1 count : 16
thread1 count : 17
thread1 count : 18
thread1 count : 19
msh >```