优先级反转实验，使用信号量实现【RT-Thread学习笔记 5】

//优先级反转实验
rt_sem_t sem;
rt_uint32_t t1_count = 0,t2_count = 0,worker_count = 0;
rt_thread_t t1,t2,worker ;

void pri1_entry(void *parameter)
{
    rt_err_t result;
    while(1)
    {
        result = rt_sem_take(sem,RT_WAITING_FOREVER);
        for(t1_count =0;t1_count<10;t1_count++)
        {
            rt_kprintf("pri1 take semphone\r\n");
            rt_thread_delay(RT_TICK_PER_SECOND);
        }
        rt_kprintf("pri1 release semphone\r\n");
        rt_sem_release(sem);
    }
}

void pri2_entry(void *parameter)
{
    //rt_uint32_t t2_count = 0;
    rt_err_t result;
    while(1)
    {
        result = rt_sem_take(sem,RT_WAITING_FOREVER);
        rt_kprintf("pri2 take semphone\r\n");
        if(result != RT_EOK)
        {
            return;
        }
        rt_kprintf("pri2 release semphone\r\n");
        rt_sem_release(sem);
        
        rt_thread_delay(5);
        result = rt_sem_take(sem,RT_WAITING_FOREVER);
        t2_count ++;
        rt_kprintf("pri2 :got semphone,count:%d\r\n",t2_count);
        result = rt_sem_release(sem);
    }
    
}

void worker_entry(void *parameter)
{
    rt_thread_delay(5);
    for(worker_count = 0;worker_count<10;worker_count++)
    {
        rt_kprintf("worker:  count: %d\n", worker_count);
    }
    rt_thread_delay(RT_TICK_PER_SECOND);

}

//信号量/优先级反转实验
    
    t1 = rt_thread_create("pri1",
        pri1_entry, RT_NULL,
        512, 8, 10);
    if (t1 != RT_NULL)
        rt_thread_startup(t1);
   
    t2 = rt_thread_create("pri2",
            pri2_entry, RT_NULL,
            512, 6, 10);
        if (t2 != RT_NULL)
            rt_thread_startup(t2);
           
    worker = rt_thread_create("worker",
            worker_entry, RT_NULL,
            512, 7, 10);
    if (worker != RT_NULL)
        rt_thread_startup(worker);
sem = rt_sem_create("sem_t",1,RT_IPC_FLAG_PRIO);