readers_and_writers.c 929 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. #include <starpu.h>
  2. static unsigned book = 0;
  3. static starpu_data_handle book_handle;
  4. static void dummy_kernel(void *descr[], void *arg)
  5. {
  6. }
  7. static starpu_codelet rw_cl = {
  8. .where = CORE|CUDA,
  9. .cuda_func = dummy_kernel,
  10. .core_func = dummy_kernel,
  11. .nbuffers = 1
  12. };
  13. int main(int argc, char **argv)
  14. {
  15. starpu_init(NULL);
  16. /* initialize the resource */
  17. starpu_register_vector_data(&book_handle, 0, (uintptr_t)&book, 1, sizeof(unsigned));
  18. unsigned ntasks = 16*1024;
  19. unsigned t;
  20. for (t = 0; t < ntasks; t++)
  21. {
  22. struct starpu_task *task = starpu_task_create();
  23. task->cl = &rw_cl;
  24. /* we randomly select either a reader or a writer (give 10
  25. * times more chances to be a reader) */
  26. task->buffers[0].mode = ((rand() % 10)==0)?STARPU_W:STARPU_R;
  27. task->buffers[0].handle = book_handle;
  28. int ret = starpu_submit_task(task);
  29. STARPU_ASSERT(!ret);
  30. }
  31. starpu_wait_all_tasks();
  32. starpu_shutdown();
  33. return 0;
  34. }