This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 3ce668c [CAMEL-15002] Add a beforeInitialize method on the
MainListener and deprecate the configure method (#3796)
new 85c2f83 CAMEL-14996: Splitter/Multicast EIP can cause a thread to
starve from endless stackframes when splitting as it does not collapse its
stackframes but keep scheduling for next split/task.
new f57e6e3 CAMEL-14996: Splitter/Multicast EIP can cause a thread to
starve from endless stackframes when splitting as it does not collapse its
stackframes but keep scheduling for next split/task.
new dcff7fe CAMEL-14996: Splitter/Multicast EIP can cause a thread to
starve from endless stackframes when splitting as it does not collapse its
stackframes but keep scheduling for next split/task.
new 875fb0e CAMEL-15008: ReactiveExecutor should run scheduled tasks more
fairly
new 6712e3d CAMEL-15008: ReactiveExecutor should run scheduled tasks more
fairly
new adb3c4b CAMEL-14996: Okay after diving more into this then
CAMEL-15008 fixed the root problem so we dont need to separate multicast eip
into parallel vs sequential task to fix the endless stack frame. So reverting
this code back and a little polish.
new 4e95bad CAMEL-14996: Splitter/Multicast EIP can cause a thread to
starve from endless stackframes when splitting as it does not collapse its
stackframes but keep scheduling for next split/task.
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/camel/spi/ReactiveExecutor.java | 7 +++
.../camel/impl/engine/DefaultReactiveExecutor.java | 5 ++
.../apache/camel/processor/MulticastProcessor.java | 19 +++---
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../processor/SplitterStreamingUoWIssueTest.java | 11 +++-
...teParallelProcessingStackOverflowIssueTest.java | 50 ++++++++++++++++
.../SplitAggregateStackOverflowIssueTest.java | 69 ++++++++++++++++++++++
...itParallelProcessingStackOverflowIssueTest.java | 42 +++++++++++++
.../aggregator/SplitStackOverflowIssueTest.java | 41 +++++++++++++
9 files changed, 234 insertions(+), 14 deletions(-)
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/aggregator/SplitAggregateParallelProcessingStackOverflowIssueTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/aggregator/SplitAggregateStackOverflowIssueTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/aggregator/SplitParallelProcessingStackOverflowIssueTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/aggregator/SplitStackOverflowIssueTest.java