RFR: WIP: add a new subclass of StructuredTaskScope that shows the finished subtasks as a Stream
Alan Bateman
Alan.Bateman at oracle.com
Fri Sep 1 13:30:11 UTC 2023
On 01/09/2023 14:23, Rémi Forax wrote:
> :
>
> The current implementation is not the right one, instead of introducing a new method into the Flock that can wait on shutdown, threadCount == 0 and the queue has a new subtask, this implementation shutdown the flock early and do not implement shutdown() so it only have to check if the number of tasks is zero.
>
>
One thing that could be useful is to start out in your own package and
use it to help identify any protected methods that might need to be
exposed to subclasses to do this themselves. SOS and SOF aren't special
for example.
Another thing that comes to mind is that you might remember the streamy
methods we had on ES in some of the early prototypes. These were used to
shake out issues with have a stream to a blocking source.
-Alan
More information about the loom-dev
mailing list