Queue¶
About¶
Use a queue to communicate between two threads.
Source code¶
/**
* @file main.c
*
* @section License
* Copyright (C) 2015-2016, Erik Moqvist
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* This file is part of the Simba project.
*/
#include "simba.h"
static struct queue_t queue;
static THRD_STACK(writer_stack, 256);
static void *writer_main(void *arg_p)
{
int value;
/* Write to the queue. */
value = 1;
queue_write(&queue, &value, sizeof(value));
return (NULL);
}
int main()
{
int value;
sys_start();
queue_init(&queue, NULL, 0);
thrd_spawn(writer_main, NULL, 0, writer_stack, sizeof(writer_stack));
/* Read from the queue. */
queue_read(&queue, &value, sizeof(value));
std_printf(FSTR("read value = %d\r\n"), value);
return (0);
}
The source code can also be found on Github in the examples/queue folder.
Build and run¶
Build and upload the application.
$ cd examples/queue
$ make -s BOARD=<board> run
read value = 1