15天入门第七天信号量的使用

发布于 2018-05-23 23:35:24 浏览：2004 订阅该版

本次课程主要讲信号量的使用，包含：
1、IPC的作用
用于任务间通信,同步,交互,才能配合完成大的事项. inter process communication
IPC对象分为:
信号量
互斥锁
信号
消息队列
邮箱

2、举例理解信号量
车位:公共资源
车:线程 任务 想占公共资源
管理员:信号量 
停车场3个车位
-------------
1  2     3

-------------
管理员
/////////////////
car 4 car 5  car 6

3、例程源码解析及信号量的相关操作
初始化(静态定义)/创建(动态)    获取   释放   删除/脱离detach静态
FIFO 常用
rt_sem_init()  -----rt_sem_detach()
rt_sem_take(rt_sem_t sem,rt_int32_t time) //0  或者一直等 
rt_sem_release(&static_sem);

rt_sem_create()   ----re)sem_delete(dynamic_sem)
4、信号量的本质:非负整数.
take 时候减1;只有大于0的时候才能获取到.否则挂起.都是take 函数中的功能.
释放的时候   信号量加1.非负整数.

5、信号量的使用注意事项 
take 不能放在中断服务程序中,不要尝试在中断程序中获取信号量.但可以在中断中释放.
作业:基于信号量实现一个定时的操作,

比如流水灯.
```static void rt_thread_entry2(void *parameter)
{
	while(1)
	{
		rt_thread_delay(RT_TICK_PER_SECOND / 2);
		 rt_sem_release(&static_sem);
	}
	
}
static void thread_entry_led(void* parameter)
{
	rt_err_t result;
	while(1)
	{
		  /* 永久等待方式持有信号量 */
    result = rt_sem_take(&static_sem, RT_WAITING_FOREVER);
    if (result != RT_EOK)
    {
        /* 不成功则测试失败 */
        rt_kprintf("take a static semaphore, failed.<br>");
        rt_sem_detach(&static_sem);
        return;
    }

rt_kprintf("take a staic semaphore, done led.<br>");
	}
}
	/* 信号量示例的初始化 */
int semaphore_sample_init()
{
    rt_err_t result;

/* 初始化静态信号量，初始值是0 */
    result = rt_sem_init(&static_sem, "ssem", 0, RT_IPC_FLAG_FIFO);
    if (result != RT_EOK)
    {
        rt_kprintf("init dynamic semaphore failed.<br>");
        return -1;
    }

/* 创建一个动态信号量，初始值是0 */
    dynamic_sem = rt_sem_create("dsem", 0, RT_IPC_FLAG_FIFO);
    if (dynamic_sem == RT_NULL)
    {
        rt_kprintf("create dynamic semaphore failed.<br>");
        return -1;
    }
		/*创建LED 任务*/
    tid2 = rt_thread_create("t2",
        thread_entry_led, (void*)2, /* 线程入口是thread_entry, 入口参数是2 */
        512, 25,5);
    if (tid2 != RT_NULL)
        rt_thread_startup(tid2);

rt_thread_init(&thread1,
                   "thread1",
                   rt_thread_entry2,
                   RT_NULL,
                   &thread1_stack[0],
                   sizeof(thread1_stack), 11, 5);
    rt_thread_startup(&thread1);

return 0;
}```