On Thu, 9 Jan 2025 15:46:56 GMT, Viktor Klang <vkl...@openjdk.org> wrote:
>> The following patch updates Gatherers.mapConcurrent to limit >> work-in-progress (on-going and completed-unpushed) to the `maxConcurrency` >> so that head-of-line blocking does not cause completed-unpushed work to grow >> unbounded. >> >> This also simplifies interruption handling to ignore-and-restore, which >> needs to be done on a per-element-basis as the calling thread can change >> between invocations of the integrator, as well as the finisher, so restoring >> it on finish is not possible (and won't happen if there's an exception >> thrown during integration anyway). >> >> Furthermore, logic has been added to reduce the risk of any spawned virtual >> threads surviving the processing of the stream. > > Viktor Klang has updated the pull request incrementally with one additional > commit since the last revision: > > Addresses PR review feedback Marked as reviewed by alanb (Reviewer). ------------- PR Review: https://git.openjdk.org/jdk/pull/22999#pullrequestreview-2542102640
