Need Help for an example of QueueMessage

[sakunamary]

Hi guys: I am learning how to use Queue of HeliOS , my code is not working ,I am not sure my codes is correct.Please do me a favor to explain how to use the function Queue in HeliOS .Thanks here is my code : main.cpp.zip

I create tasks, task1 and task2 are just sending message to queue ,and taskprint will read the message and print it out . It's very simple . Question 1 :So should I suppose to create a xQueue Queue1 = xQueueCreate(8) ？ Question2: How can I get the handler of Queue in Task?

void Task1(xTask task, xTaskParm parm) { char userID="1"; xQueue Queue1; -------> for Queue1 handler Am I correct ? if I omit this line ,compiler will error : Queue1 is not declared. if (xQueueIsQueueFull(Queue1) == false ){ xQueueSend(Queue1, 1, "1" ); Serial.println("TASK1 sended");
} else { Serial.println("QueueMsg is full");
}
}

Thanks you again!!!! Best wishes!!!

[MannyPeterson]

@sakunamary

Good question, so there are a few ways. The most appropriate way is to create the queue in your setup() function. Then pass the queue to both tasks using the task parameter.

xQueue queue1 = xCreateQueue(8);

xTask task1 = xCreateTask("TASK1", task1_main, queue1);

xTask task2 = xCreateTask("TASK2", task2_main, queue1);

Inside the task main functions you would cast "parm_" to an xQueue so you can call the queue system calls.

I hope that helps!

Manny

[sakunamary]

@MannyPeterson

I have tried the way you show me ,but is not working . here is the task function:

part1: create xQueue in setup() and then create two task send and receive as your way:

    xQueue Queue1 = xQueueCreate(8);

    xTask task1 = xTaskCreate("TASK1", Task1,  Queue1 );
    xTask taskPrint = xTaskCreate("PRINT", TaskPrint, Queue1);

Part 2: passthrough the xQueue in the task function :

  void Task1(xTask task_, xTaskParm parm_) {
xQueue queue =  DEREF_TASKPARM(xQueue, parm_);   -------> passthrough  Queue1 into queue 
        if (xQueueIsQueueFull(queue) == false ){
                xQueueSend(queue,
                             1, 
                            '1' );
            Serial.println("TASK1 sended");     

            } else  {
            Serial.println("QueueMsg is full");                    
            }

  DEREF_TASKPARM(xQueue, parm_) = queue; ----------->deref queue 
  return;
}       

Task to print the queue :

void TaskPrint(xTask task_, xTaskParm parm_) {
char* str ;
byte num;
xQueue Queue1 =  DEREF_TASKPARM(xQueue, parm_);   
xQueueMessage  Msg=xQueueReceive(Queue1);

    str = Msg->messageValue;
    num = Msg->messageBytes;
    Serial.print("RECIVE Queue:");
    Serial.println(str);

    Serial.print("RECIVE byte:");
    Serial.println(num);

  DEREF_TASKPARM(xQueue, parm_) = Queue1;
  return;       
}

OUTPUT is not what I suppose , now is

RECIVE Queue: -------->empty and suppose is 1 or 2 RECIVE byte:0 --------> suppose is 0

here is the pgm after modify. main.cpp.zip

Thanks for your answering again!!! Best wishes !!!

[MannyPeterson]

@sakunamary

Apologies for the delay. I will compile and try running your code.

[sakunamary]

@sakunamary

Apologies for the delay. I will compile and try running your code.

No problem at all . Don't be rush, just take your time...I am writing some examples ino file for HeliOS.

[MannyPeterson]

@sakunamary thank you for your interest and contribution!