一个任务如何在多个 vxworks 队列上等待？

我们有一个 vxWorks 设计，需要一个任务来处理来自两个消息队列 Q1 和 Q2 的消息。

我们希望在两个队列上等待，无论哪个队列收到消息，都处理队列中的消息。

我们希望避免轮询队列或使用可能导致其他队列填满的超时值。

有没有办法做到这一点？

如果使用命名管道（pipeDevCreate()、write()、read()）而不是消息队列，则可以使用 select() 进行阻塞，直到任一管道中有消息为止。

每当 select() 触发时，您就会处理高优先级管道中的所有消息。然后处理来自低优先级管道的一条消息。然后再次调用 select （循环）。

示例代码片段：

 // Initialization: Create high and low priority named pipes
 pipeDrv(); //initialize pipe driver
 int fdHi = pipeDevCreate("/pipe/high",numMsgs,msgSize);
 int fdLo = pipeDevCreate("/pipe/low",numMsgs,msgSize);

 ...

 // Message sending thread: Add messages to pipe
 write(fdHi, buf, sizeof(buf));

 ...

 // Message processing Thread: select loop
 fd_set rdFdSet;

 while(1)
 {
     FD_ZERO(&rdFdSet);
     FD_SET(fdHi, &rdFdSet);
     FD_SET(fdLo, &rdFdSet;

     if (select(FD_SETSIZE, &rdFdSet, NULL, NULL, NULL) != ERROR)
     {
         if (FD_ISSET(fdHi, &rdFdSet))
         {
             // process all high-priority messages
             while(read(fdHi,buf,size) > 0)
             {
                 //process high-priority
             }
         }

         if (FD_ISSET(fdLo, &rdFdSet))
         {
             // process a single low priority message
             if (read(fdLo,buf,size) > 0)
             {
                 // process low priority
             }
         }
     }
 }