event_simple.c 3.9 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
/*
 * 程序清单:事件例程
 *
 * 这个程序会创建3个动态线程及初始化一个静态事件对象
 * 一个线程等于事件对象上以接收事件;
 * 一个线程定时发送事件 (事件3)
 * 一个线程定时发送事件 (事件5)
 */
#include <rtthread.h>
#include "tc_comm.h"

/* 指向线程控制块的指针 */
static rt_thread_t tid1 = RT_NULL;
static rt_thread_t tid2 = RT_NULL;
static rt_thread_t tid3 = RT_NULL;

B
bernard.xiong 已提交
17 18
/* 事件控制块 */
static struct rt_event event;
19

B
bernard.xiong 已提交
20 21
/* 线程1入口函数 */
static void thread1_entry(void *param)
22
{
G
Grissiom 已提交
23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47
    rt_uint32_t e;

    while (1)
    {
        /* receive first event */
        if (rt_event_recv(&event, ((1 << 3) | (1 << 5)),
                          RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR,
                          RT_WAITING_FOREVER, &e) == RT_EOK)
        {
            rt_kprintf("thread1: AND recv event 0x%x\n", e);
        }

        rt_kprintf("thread1: delay 1s to prepare second event\n");
        rt_thread_delay(10);

        /* receive second event */
        if (rt_event_recv(&event, ((1 << 3) | (1 << 5)),
                          RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
                          RT_WAITING_FOREVER, &e) == RT_EOK)
        {
            rt_kprintf("thread1: OR recv event 0x%x\n", e);
        }

        rt_thread_delay(5);
    }
48 49
}

B
bernard.xiong 已提交
50 51
/* 线程2入口函数 */
static void thread2_entry(void *param)
52
{
G
Grissiom 已提交
53 54 55 56
    while (1)
    {
        rt_kprintf("thread2: send event1\n");
        rt_event_send(&event, (1 << 3));
57

G
Grissiom 已提交
58 59
        rt_thread_delay(10);
    }
60 61
}

B
bernard.xiong 已提交
62 63
/* 线程3入口函数 */
static void thread3_entry(void *param)
64
{
G
Grissiom 已提交
65 66 67 68
    while (1)
    {
        rt_kprintf("thread3: send event2\n");
        rt_event_send(&event, (1 << 5));
69

G
Grissiom 已提交
70 71
        rt_thread_delay(20);
    }
72 73 74 75
}

int event_simple_init()
{
G
Grissiom 已提交
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106
    /* 初始化事件对象 */
    rt_event_init(&event, "event", RT_IPC_FLAG_FIFO);

    /* 创建线程1 */
    tid1 = rt_thread_create("t1",
                            thread1_entry, RT_NULL, /* 线程入口是thread1_entry, 入口参数是RT_NULL */
                            THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
    if (tid1 != RT_NULL)
        rt_thread_startup(tid1);
    else
        tc_stat(TC_STAT_END | TC_STAT_FAILED);

    /* 创建线程2 */
    tid2 = rt_thread_create("t2",
                            thread2_entry, RT_NULL, /* 线程入口是thread2_entry, 入口参数是RT_NULL */
                            THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
    if (tid2 != RT_NULL)
        rt_thread_startup(tid2);
    else
        tc_stat(TC_STAT_END | TC_STAT_FAILED);

    /* 创建线程3 */
    tid3 = rt_thread_create("t3",
                            thread3_entry, RT_NULL, /* 线程入口是thread3_entry, 入口参数是RT_NULL */
                            THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
    if (tid3 != RT_NULL)
        rt_thread_startup(tid3);
    else
        tc_stat(TC_STAT_END | TC_STAT_FAILED);

    return 0;
107 108 109 110 111
}

#ifdef RT_USING_TC
static void _tc_cleanup()
{
G
Grissiom 已提交
112 113
    /* 调度器上锁,上锁后,将不再切换到其他线程,仅响应中断 */
    rt_enter_critical();
114

G
Grissiom 已提交
115 116 117 118 119 120 121
    /* 删除线程 */
    if (tid1 != RT_NULL && tid1->stat != RT_THREAD_CLOSE)
        rt_thread_delete(tid1);
    if (tid2 != RT_NULL && tid2->stat != RT_THREAD_CLOSE)
        rt_thread_delete(tid2);
    if (tid3 != RT_NULL && tid3->stat != RT_THREAD_CLOSE)
        rt_thread_delete(tid3);
122

G
Grissiom 已提交
123 124
    /* 执行事件对象脱离 */
    rt_event_detach(&event);
B
bernard.xiong 已提交
125

G
Grissiom 已提交
126 127
    /* 调度器解锁 */
    rt_exit_critical();
128

G
Grissiom 已提交
129 130
    /* 设置TestCase状态 */
    tc_done(TC_STAT_PASSED);
131 132 133 134
}

int _tc_event_simple()
{
G
Grissiom 已提交
135 136 137
    /* 设置TestCase清理回调函数 */
    tc_cleanup(_tc_cleanup);
    event_simple_init();
138

G
Grissiom 已提交
139 140
    /* 返回TestCase运行的最长时间 */
    return 100;
141 142 143 144 145 146 147
}
/* 输出函数命令到finsh shell中 */
FINSH_FUNCTION_EXPORT(_tc_event_simple, a simple event example);
#else
/* 用户应用入口 */
int rt_application_init()
{
G
Grissiom 已提交
148
    event_simple_init();
149

G
Grissiom 已提交
150
    return 0;
151 152
}
#endif