src/lib/concurrency.slate

   1
   2 "Slate based concurrency"
   3
   4 prototypes ensureNamespace: #concurrency &delegate: True.
   5
   6 concurrency define: #Process &parents: {Cloneable}
   7  &slots: {#pipes -> ExtensibleArray new}.
   8
   9
  10 p@(Process traits) forkAndDo: b
  11 [ | ret |
  12   ret := (lobby cloneSystem).
  13   ret first ifTrue: [p pipes addLast: ret second. ret second]
  14             ifFalse: [[p pipes clear. p pipes addLast: ret second. b applyWith: ret second] ensure: [lobby quit]]
  15 ].
  16
  17
  18 concurrency addSlot: #currentProcess valued: Process new.