Mercurial > hg > GearsTemplate
view src/parallel_execution/TaskIterator.cbc @ 458:3025d00eb87d
Merge
author | Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Thu, 14 Dec 2017 07:44:58 +0900 |
parents | 95f58f2b2c0e |
children | 8d7e5d48cad3 |
line wrap: on
line source
#include "../context.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(...); }