mirror of
https://github.com/RIOT-OS/RIOT.git
synced 2024-12-29 04:50:03 +01:00
Add pthread_barrier test
This commit is contained in:
parent
9202a482d5
commit
503e95af0b
18
tests/test_pthread_barrier/Makefile
Normal file
18
tests/test_pthread_barrier/Makefile
Normal file
@ -0,0 +1,18 @@
|
||||
# name of your application
|
||||
PROJECT = test_pthread_barrier
|
||||
include ../Makefile.tests_common
|
||||
|
||||
## Modules to include.
|
||||
USEMODULE += pthread
|
||||
USEMODULE += random
|
||||
USEMODULE += vtimer
|
||||
|
||||
CFLAGS += -isystem $(RIOTBASE)/sys/posix/pthread/include
|
||||
CFLAGS += -isystem $(RIOTBASE)/sys/posix/include
|
||||
|
||||
INCLUDES += -I$(RIOTBASE)/sys/posix/pthread/include
|
||||
INCLUDES += -I$(RIOTBASE)/sys/posix/include
|
||||
|
||||
CFLAGS += -ggdb3 -O0
|
||||
|
||||
include $(RIOTBASE)/Makefile.include
|
74
tests/test_pthread_barrier/main.c
Normal file
74
tests/test_pthread_barrier/main.c
Normal file
@ -0,0 +1,74 @@
|
||||
/*
|
||||
* Copyright (C) 2014 Freie Universität Berlin
|
||||
*
|
||||
* This file is subject to the terms and conditions of the GNU Lesser General
|
||||
* Public License. See the file LICENSE in the top level directory for more
|
||||
* details.
|
||||
*/
|
||||
|
||||
/**
|
||||
* @ingroup tests
|
||||
* @{
|
||||
*
|
||||
* @file
|
||||
* @brief pthread_barrier test
|
||||
*
|
||||
* @author René Kijewski <rene.kijewski@fu-berlin.de>
|
||||
*
|
||||
* @}
|
||||
*/
|
||||
|
||||
#include <stdio.h>
|
||||
|
||||
#include "pthread.h"
|
||||
#include "random.h"
|
||||
#include "vtimer.h"
|
||||
|
||||
#define NUM_CHILDREN 4
|
||||
#define NUM_ITERATIONS 5
|
||||
|
||||
#define RAND_SEED 0xC0FFEE
|
||||
|
||||
static pthread_barrier_t barrier;
|
||||
|
||||
static void *run(void *id_)
|
||||
{
|
||||
int id = (intptr_t) id_ + 1;
|
||||
printf("Start %i\n", id);
|
||||
|
||||
for (int i = 1; i <= NUM_ITERATIONS; ++i) {
|
||||
if (id == NUM_CHILDREN) {
|
||||
puts("\n======================================\n");
|
||||
}
|
||||
pthread_barrier_wait(&barrier);
|
||||
|
||||
uint32_t timeout_us = genrand_uint32() % 2500000;
|
||||
printf("Child %i sleeps for % 8i µs.\n", id, timeout_us);
|
||||
vtimer_usleep(timeout_us);
|
||||
}
|
||||
|
||||
printf("Done %i\n", id);
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int main(void)
|
||||
{
|
||||
genrand_init(RAND_SEED);
|
||||
|
||||
puts("Start.\n");
|
||||
pthread_barrier_init(&barrier, NULL, NUM_CHILDREN);
|
||||
|
||||
pthread_t children[NUM_CHILDREN];
|
||||
for (int i = 0; i < NUM_CHILDREN; ++i) {
|
||||
pthread_create(&children[i], NULL, run, (void *) (intptr_t) i);
|
||||
}
|
||||
|
||||
for (int i = 0; i < NUM_CHILDREN; ++i) {
|
||||
void *void_;
|
||||
pthread_join(children[i], &void_);
|
||||
}
|
||||
|
||||
pthread_barrier_destroy(&barrier);
|
||||
puts("\nDone.");
|
||||
return 0;
|
||||
}
|
Loading…
Reference in New Issue
Block a user