Mercurial > hg > Gears > GearsAgda
view src/parallel_execution/TaskIterator.cbc @ 479:b8b412a7670a
Fix segmentation fault if multithread
author | Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Thu, 28 Dec 2017 19:51:06 +0900 |
parents | ac244346c85d |
children |
line wrap: on
line source
#include "../context.h" #interface "Iterator.h" #include <stdio.h> createTaskIterator(struct Context, struct List list) { struct Iterator* iterator = new Iterator(); struct TaskIterator* taskIterator = new TaskIterator(); iterator->itearot = (union Data*)taskIterator; iterator->exec = C_execTaskIterator; iterator->barrier = C_barrierTaskIterator; taskIterator->taskList = list; } __code execTaskIterator(struct taskIterator* iterator, struct TaskManager* taskManager, struct Context* task, __code next(...)) { if (iterator->list->next == null) { goto next(...); } iterator->list = list->next; struct Context* task = (struct Context*)iterator->list->data; struct TaskManager taskManager = task->taskManager; taskManager->spawn(task, C_execTaskIterator); } __code barrierTaskIterator(struct MultiDimIterator* iterator, struct Context* task, __code next(...), __code whenWait(...)) { if (__sync_fetch_and_sub(&iterator->count, 1) == 1) { goto next(...); } goto whenWait(...); }