github-starred/ultimatepp
2
0
Fork 0
mirror of https://github.com/ultimatepp/ultimatepp.git synced 2026-07-11 22:03:01 -06:00
Code Issues 33 Projects Packages Wiki Activity Actions

.docs

Browse source 
git-svn-id: svn://ultimatepp.org/upp/trunk@11629 f0d560ea-af0d-0410-9eb7-867de7ffcac7
This commit is contained in:
cxl 2017-12-26 10:26:27 +00:00
parent 4d46becbf3
commit 148339f28f
2 changed files with 27 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
uppsrc/Core/CoWork.h
View file

@ -76,11 +76,12 @@ public:
void Loop(Function<void ()>&& fn);
void Loop(const Function<void ()>& fn) { Loop(clone(fn)); }
int Next() { return ++index - 1; }
CoWork& operator*(const Function<void ()>& fn) { Loop(fn); return *this; }
CoWork& operator*(Function<void ()>&& fn) { Loop(pick(fn)); return *this; }
int Next() { return ++index - 1; }
void Pipe(int stepi, Function<void ()>&& lambda); // experimental
static void FinLock();

25
uppsrc/Core/src.tpp/CoWork_en-us.tpp
View file

@ -80,6 +80,31 @@ not specified. In certain situations (no scheduling slot available),
Do can perform scheduled job immediately in calling thread.&]
[s3;%% &]
[s4; &]
[s5;:Upp`:`:CoWork`:`:Loop`(Upp`:`:Function`<void`(`)`>`&`&`): [@(0.0.255) void]_[* Loop](
[_^Upp`:`:Function^ Function]<[@(0.0.255) void]_()>`&`&_[*@3 fn])&]
[s5;:Upp`:`:CoWork`:`:Loop`(const Upp`:`:Function`<void`(`)`>`&`): [@(0.0.255) void]_[* L
oop]([@(0.0.255) const]_[_^Upp`:`:Function^ Function]<[@(0.0.255) void]_()>`&_[*@3 fn])&]
[s5;:Upp`:`:CoWork`:`:operator`*`(const Upp`:`:Function`<void`(`)`>`&`): [_^Upp`:`:CoWork^ C
oWork][@(0.0.255) `&]_[* operator`*]([@(0.0.255) const]_[_^Upp`:`:Function^ Function]<[@(0.0.255) v
oid]_()>`&_[*@3 fn])&]
[s5;:Upp`:`:CoWork`:`:operator`*`(Upp`:`:Function`<void`(`)`>`&`&`): [_^Upp`:`:CoWork^ C
oWork][@(0.0.255) `&]_[* operator`*]([_^Upp`:`:Function^ Function]<[@(0.0.255) void]_()>`&
`&_[*@3 fn])&]
[s2;%% Schedules [%-*@3 fn] to be run on all worker threads. After
the first thread returns from [%-*@3 fn], all other scheduled [%-*@3 fn]
jobs that has not started yet are unscheduled. Waits for all
started jobs to finish. The function also sets internal index
counter to zero in CoWork before starting any worker thread.
Worker thread should acquire job quantum in internal loop `-
internal CoWork index can be used for this purpose.&]
[s3;%% &]
[s4; &]
[s5;:Upp`:`:CoWork`:`:Next`(`): [@(0.0.255) int]_[* Next]()&]
[s2;%% Atomically increments internal index counter and returns its
previous value (thus the first value returned is 0). Supposed
to be used with Loop.&]
[s3; &]
[s4; &]
[s5;:Upp`:`:CoWork`:`:FinLock`(`): [@(0.0.255) static] [@(0.0.255) void]_[* FinLock]()&]
[s2;%% This functions is to be called in scheduled routine. Its purpose
is to serialize access to shared data at the end of the routine.