请教关于消息队列的使用问题

发布于 2020-04-19 15:18:10 浏览：1301 订阅该版

13 个回答

alyoh 2020-04-19

这家伙很懒，什么也没写！

alyoh 2020-04-19

这家伙很懒，什么也没写！

alyoh 2020-04-20

这家伙很懒，什么也没写！

alyoh 2020-04-20

这家伙很懒，什么也没写！

gdolphin 2020-04-20

这家伙很懒，什么也没写！

alyoh 2020-04-20

这家伙很懒，什么也没写！

gdolphin 2020-04-20

这家伙很懒，什么也没写！

alyoh 2020-04-21

这家伙很懒，什么也没写！

alyoh 2020-04-21

这家伙很懒，什么也没写！

alyoh 2020-04-21

这家伙很懒，什么也没写！

```
#include <rtthread.h>
#include <stdio.h>

static struct rt_messagequeue mq_tst;
static rt_uint8_t tst_pool[160];

ALIGN(RT_ALIGN_SIZE)
static char Tst1_stack[256];
static struct rt_thread Tst1_Thread;

static void thread1_entry(void *parameter)
{
    while(1)
    {
        printf("Thread1-Run\n");
        rt_thread_mdelay(100);
    }
}

ALIGN(RT_ALIGN_SIZE)
static char Tst2_stack[256];
static struct rt_thread Tst2_Thread;

static void thread2_entry(void *parameter)
{
    static char TxMsg;

while(1)
    {
        printf("Thread2-Run\n");
        if (rt_mq_recv(&mq_tst, &TxMsg, sizeof(TxMsg), RT_WAITING_FOREVER) == RT_EOK)
        {
            TxMsg = '0';
        }
    }
}

static void hook_of_scheduler(struct rt_thread* from, struct rt_thread* to)
{
    printf("from: %s -->  to: %s \n", from->name , to->name);
}

int Thread_Thread(void)
{
    /* 设置调度器钩子 */
    rt_scheduler_sethook(hook_of_scheduler);
    
    /* 初始化消息队列 */
    rt_mq_init(&mq_tst,
                    "tst_mq",                      /* 名称是tst_mq */
                    &tst_pool[0],               /* 消息队列用到的内存池是tst_pool */
                    sizeof(char),            /* 每个消息的大小  */
                    sizeof(tst_pool),           /* 消息队列大小 */
                    RT_IPC_FLAG_FIFO);          /* 采用FIFO方式进行线程等待 */

rt_thread_init(&Tst2_Thread,
                   "Thd_2",
                   thread2_entry,
                   RT_NULL,
                   &Tst2_stack[0],
                   sizeof(Tst2_stack),
                   10, 5);
    rt_thread_startup(&Tst2_Thread); 
                   
    rt_thread_init(&Tst1_Thread,
                   "Thd_1",
                   thread1_entry,
                   RT_NULL,
                   &Tst1_stack[0],
                   sizeof(Tst1_stack),
                   15, 5);
    rt_thread_startup(&Tst1_Thread);

return 1;
}

```

这是在5.6.1版本的CubeMX + 3.1.3RtThread库生成的Keil5下调用的代码,最大中断等级32.

预期是优先级10的rt_mq_recv挂起,然后间隔调用优先等级15的线程.
实际表现为低优先级没有进入过.

准备测试其他方式移植的内核