05_parallel.c File Reference

#include <stdatomic.h>
#include <stdio.h>
#include <serene/runtime.h>

Include dependency graph for 05_parallel.c:

Go to the source code of this file.

Macros
#define	FIBER_COUNT   1000
#define	WORKER_COUNT   4

Functions
static srn_fiber_result_t	increment (srn_context_t *ctx, void *arg)
int	main (void)

Variables
static atomic_int	total

Macro Definition Documentation

FIBER_COUNT

#define FIBER_COUNT   1000

Definition at line 37 of file 05_parallel.c.

WORKER_COUNT

#define WORKER_COUNT   4

Definition at line 38 of file 05_parallel.c.

Function Documentation

increment()

srn_fiber_result_t increment ( srn_context_t * ctx, void * arg )

static

Definition at line 42 of file 05_parallel.c.

                                                                   {
  (void)ctx;
  (void)arg;
  // The one piece of shared state. An atomic add is safe from any worker.
  atomic_fetch_add(&total, 1);
  return nullptr;
}

Here is the caller graph for this function:

main()

int main

(

void

)

Definition at line 50 of file 05_parallel.c.

               {
  SERENE_RUNTIME_INIT_WITH_SCHED(engine, sched, nullptr);
  srn_context_t *ctx = srn_context_make(engine);
 
  atomic_store(&total, 0);
  for (int i = 0; i < FIBER_COUNT; i++) {
    (void)srn_fiber_spawn(ctx, increment, nullptr);
  }
 
  printf("running %d fibers across %d workers\n", FIBER_COUNT, WORKER_COUNT);
  srn_sched_run(sched, WORKER_COUNT);
 
  int counted = atomic_load(&total);
  printf(
    "counted %d (expected %d): %s\n", counted, FIBER_COUNT,
    counted == FIBER_COUNT ? "all fibers ran" : "lost an update"
  );
 
  srn_context_release(ctx);
  SERENE_RUNTIME_SHUTDOWN(engine);
  return 0;
}

Here is the call graph for this function:

Variable Documentation

total

atomic_int total

static

Definition at line 40 of file 05_parallel.c.