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 int	ok
static atomic_int	total

Macro Definition Documentation

FIBER_COUNT

#define FIBER_COUNT   1000

Definition at line 39 of file 05_parallel.c.

WORKER_COUNT

#define WORKER_COUNT   4

Definition at line 40 of file 05_parallel.c.

Function Documentation

increment()

static srn_fiber_result_t increment ( srn_context_t * ctx, void * arg )

static

Definition at line 44 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 &ok;
}

Here is the caller graph for this function:

main()

int main

(

void

)

Definition at line 52 of file 05_parallel.c.

               {
  srn_mm_t *mm = srn_mm_init();
  srn_engine_t *engine = srn_engine_make(mm);
  srn_context_t *ctx = srn_context_make(engine);
  srn_scheduler_t *sched = engine->scheduler;
 
  atomic_store(&total, 0);
  for (int i = 0; i < FIBER_COUNT; i++) {
    (void)srn_fiber_make(ctx, sched, increment, nullptr, 0);
  }
 
  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);
  srn_engine_shutdown(engine);
  srn_mm_shutdown(mm);
  return 0;
}

Here is the call graph for this function:

Variable Documentation

ok

int ok

static

Definition at line 37 of file 05_parallel.c.

total

atomic_int total

static

Definition at line 42 of file 05_parallel.c.