CMSIS RTOSv2 API Example

#include "cmsis_os2.h" // CMSIS RTOS header file

/*----------------------------------------------------------------------------

* Message Queue creation & usage

*---------------------------------------------------------------------------*/

void Thread_MsgQueue1 (void *argument); // thread function 1

void Thread_MsgQueue2 (void *argument); // thread function 2

osThreadId_t tid_Thread_MsgQueue1; // thread id 1

osThreadId_t tid_Thread_MsgQueue2; // thread id 2

osEventFlagsId_t evt_id; // event flags id

#define FLAGS_MSK 0x00000001ul

#define MSGQUEUE_OBJECTS 16 // number of Message Queue Objects

typedef struct { // object data type

uint8_t Buf[32];

uint8_t Idx;

} MSGQUEUE_OBJ_t;

osMessageQueueId_t mid_MsgQueue; // message queue id

int Init_MsgQueue (void) {

//osThreadAttr_t thread_attr;

//memset(&thread_attr, 0, sizeof(thread_attr));

//thread_attr.priority = osPriorityHigh; // set initial thread priority to high

mid_MsgQueue = osMessageQueueNew(MSGQUEUE_OBJECTS, sizeof(MSGQUEUE_OBJ_t), NULL);

if (!mid_MsgQueue) {

; // Message Queue object not created, handle failure

}

tid_Thread_MsgQueue1 = osThreadNew (Thread_MsgQueue1, NULL, NULL);

if (!tid_Thread_MsgQueue1) return(-1);

tid_Thread_MsgQueue2 = osThreadNew (Thread_MsgQueue2, NULL, NULL);

if (!tid_Thread_MsgQueue2) return(-1);

return(0);

}

void Thread_MsgQueue1 (void *argument) {

MSGQUEUE_OBJ_t msg;

evt_id = osEventFlagsNew(NULL);

while (1) {

; // Insert thread code here...

msg.Buf[0] = 0x55; // do some work...

msg.Idx = 0;

osMessageQueuePut (mid_MsgQueue, &msg, 0, NULL); // returns instantly

// wait for an infinite time until the message is delivered

//osMessageQueuePut (mid_MsgQueue, &msg, 0, osWaitForever);

osEventFlagsSet(evt_id, FLAGS_MSK);

//osThreadFlagsSet(tid_Thread_MsgQueue2, FLAGS_MSK);

osThreadYield (); // suspend thread

}

}

void Thread_MsgQueue2 (void *argument) {

MSGQUEUE_OBJ_t msg;

osStatus_t status;

uint32_t flags;

while (1) {

; // Insert thread code here...

flags = osEventFlagsWait (evt_id, FLAGS_MSK, osFlagsWaitAny, osWaitForever);

//flags = osThreadFlagsWait (FLAGS_MSK, osFlagsWaitAny, osWaitForever);

//handle event

status = osMessageQueueGet (mid_MsgQueue, &msg, NULL, NULL); // returns instantly

// wait for an infinite time until the message is retrieved

//status = osMessageQueueGet (mid_MsgQueue, &msg, NULL, osWaitForever);

if (status == osOK) {

; // process data

}

}

}

/*----------------------------------------------------------------------------

* Application main thread

*---------------------------------------------------------------------------*/

void app_main (void *argument) {

// ...

// Infinite loop

for (;;) {

osDelay(1);

}

}

// Application entry point

int main(void) {

// System Initialization

// Update SystemCoreClock variable

SystemCoreClockUpdate();

// ...

//GPIO_Init();

osKernelInitialize(); // Initialize CMSIS-RTOS for creating objects

// initialize peripherals here

osThreadNew(app_main, NULL, NULL); // Create application main thread

osKernelStart(); // Start thread execution

for (;;) {}

}