PlanInMotion [1017184]

< > BotCompany Repo | #1017184 // PlanInMotion

JavaX fragment (include)

sclass PlanInMotion<A> extends DynamicObject {
  L<A> doneSteps = synchroList();
  L<A> plannedSteps = synchroLinkedList();
  volatile bool paused, cancelled;
  
  *() {}
  *(Iterable<A> l) { addAll(plannedSteps, l); }
  
  void add(A a) { plannedSteps.add(a); }
  
  IterableIterator<A> master() {
    ret iteratorFromFunction(func -> A { master_next() });
  }
  
  A master_next() {
    ret paused || cancelled ? null
      : addAndReturnIfNotNull(doneSteps, syncPopFirst(plannedSteps));
  }
}

Travelled to 14 computer(s): aoiabmzegqzx, bhatertpkbcr, cbybwowwnfue, cfunsshuasjs, gwrvuhgaqvyk, irmadwmeruwu, ishqpsrjomds, lpdgvwnxivlt, mqqgnosmbjvj, pyentgdyhuwx, pzhvpgtvlbxg, tslmcundralx, tvejysmllsmz, vouqrxazstgt

Snippet ID:

#1017184

Snippet name:

PlanInMotion

Eternal ID of this version:

#1017184/10

Text MD5:

587e84152e5b2f5df0dae954ccc1ac99

Author:

stefan

Category:

javax / a.i.

Type:

JavaX fragment (include)

Public (visible to everyone):

Yes

Archived (hidden from active list):

Created/modified:

2018-08-23 16:55:20

Source code size:

513 bytes / 19 lines

Pitched / IR pitched:

No / No

Views / Downloads:

424 / 978

Version history:

9 change(s)

Referenced in:

[show references]

1	sclass PlanInMotion<A> extends DynamicObject {
2	L<A> doneSteps = synchroList();
3	L<A> plannedSteps = synchroLinkedList();
4	volatile bool paused, cancelled;
5
6	*() {}
7	*(Iterable<A> l) { addAll(plannedSteps, l); }
8
9	void add(A a) { plannedSteps.add(a); }
10
11	IterableIterator<A> master() {
12	ret iteratorFromFunction(func -> A { master_next() });
13	}
14
15	A master_next() {
16	ret paused \|\| cancelled ? null
17	: addAndReturnIfNotNull(doneSteps, syncPopFirst(plannedSteps));
18	}
19	}