equal
deleted
inserted
replaced
372 |
372 |
373 init:size |
373 init:size |
374 "initialize the receiver for size entries" |
374 "initialize the receiver for size entries" |
375 |
375 |
376 super init:size. |
376 super init:size. |
377 dataAvailable := Semaphore new name:'shared q-read'. |
377 dataAvailable := Semaphore name:'shared q-read'. |
378 dataAvailable owner:self. |
378 dataAvailable owner:self. |
379 spaceAvailable := (Semaphore new:size) name:'shared q-write'. |
379 spaceAvailable := (Semaphore new:size) name:'shared q-write'. |
380 spaceAvailable owner:self. |
380 spaceAvailable owner:self. |
381 accessLock := RecursionLock new. |
381 accessLock := RecursionLock new. |
382 |
382 |
383 "Modified: 25.1.1997 / 00:19:45 / cg" |
383 "Modified: / 09-08-2017 / 11:59:38 / cg" |
384 ! ! |
384 ! ! |
385 |
385 |
386 !SharedQueue methodsFor:'private'! |
386 !SharedQueue methodsFor:'private'! |
387 |
387 |
388 commonWriteWith:aBlock |
388 commonWriteWith:aBlock |