message.c

提供一个简单的任务间通信方式测试c代码：消息邮箱（mailbox）通信

/*
*********************************************************************************************************
*                                                uC/OS-II
*                                          The Real-Time Kernel
*
*                           (c) Copyright 2008, ???, ??????
*                                           All Rights Reserved
* 
*
*
* Filename     : test_mailbox.c
* Programmer(s): ???
* DESCRIPTION  : This file illustrate the usage of Message Mailbox.
*
*********************************************************************************************************
*/

#include "includes.h"
/*
*********************************************************************************************************
*                                                 TYPE
*********************************************************************************************************
*/

typedef  char                        MESSAGE;    /* 消息为单个字符                                          */


/*
*********************************************************************************************************
*                                               CONSTANTS
*********************************************************************************************************
*/

#define  TASK_STK_SIZE                 256       /* Size of each task's stacks (# of WORDs)            */
#define  N_TASKS                         2       /* Number of identical tasks                          */

 

/*
*********************************************************************************************************
*                                               VARIABLES
*********************************************************************************************************
*/

OS_STK        TaskStk[N_TASKS][TASK_STK_SIZE];        /* Tasks stacks                                  */
OS_STK        TaskStartStk[TASK_STK_SIZE];

OS_EVENT     *Mailbox;

                       
/*
*********************************************************************************************************
*                                           FUNCTION PROTOTYPES
*********************************************************************************************************
*/

        void  TaskStart(void *data);                  /* Function prototypes of Startup task           */
static  void  MboxPend(void *data);                   /* 等待字符的进程                                */
static  void  MboxPost(void *data);                   /* 发送字符的进程                                */


/*
*********************************************************************************************************
*                                                MAIN
*********************************************************************************************************
*/

void  main (void)
{
  
    PC_DispClrScr(DISP_FGND_WHITE + DISP_BGND_BLACK);      /* Clear the screen                         */
    
    
    OSInit();                                              /* Initialize uC/OS-II                      */

    PC_DOSSaveReturn();                                    /* Save environment to return to DOS        */
    PC_VectSet(uCOS, OSCtxSw);                             /* Install uC/OS-II's context switch vector */

    
    OSTaskCreate(TaskStart, (void *)0, &TaskStartStk[TASK_STK_SIZE - 1], 0);
    OSStart();                                             /* Start multitasking                       */
}


/*
*********************************************************************************************************
*                                              STARTUP TASK
*********************************************************************************************************
*/
void  TaskStart (void *pdata)
{
#if OS_CRITICAL_METHOD == 3                                /* Allocate storage for CPU status register */
    OS_CPU_SR  cpu_sr;
#endif
    INT16S     key;

    pdata = pdata;                                         /* Prevent compiler warning                 */

    OS_ENTER_CRITICAL();
    PC_VectSet(0x08, OSTickISR);                           /* Install uC/OS-II's clock tick ISR        */
    PC_SetTickRate(OS_TICKS_PER_SEC);                      /* Reprogram tick rate                      */
    OS_EXIT_CRITICAL();
    
    Mailbox = OSMboxCreate((void *) 0);


    OSTaskCreate(MboxPost, 0, &TaskStk[0][TASK_STK_SIZE - 1], 2);
    OSTaskCreate(MboxPend, 0, &TaskStk[1][TASK_STK_SIZE - 1], 3);

    for (;;) {
        if (PC_GetKey(&key) == TRUE) {                     /* See if key has been pressed              */
            if (key == 0x1B) {                             /* Yes, see if it's the ESCAPE key          */
                PC_DOSReturn();                            /* Return to DOS                            */
            }
        }

        OSTimeDlyHMSM(0, 0, 1, 0);                         /* Wait one second                          */
    }
}


static  void  MboxPost (void *pdata)
{   
    MESSAGE msg;
     
    for (msg = 'A'; msg <= 'Z'; msg++){
        OSMboxPost(Mailbox, &msg);
        OSTimeDly(1); 
        if (msg == 'Z'){
            msg = 'A';
        }
    }
}


static  void  MboxPend (void *pdata)
{
    MESSAGE  msg;
    INT16U   i;
    INT8U    err;
    
    for (i = 0;; ++i){
        msg = *(MESSAGE*)OSMboxPend(Mailbox, 0, &err);

        PC_DispChar(i % 80, i / 80, msg, DISP_FGND_WHITE);
        OSTimeDly(3);         
        if (i > 2000){
            i = 0;
        }
    }
}