test: 添加 NPE 复现测试用于 GitHub Actions 验证

问题背景:
- PatternTest.shouldOkWhenAiFlowWithExampleSelector 在 GitHub Actions 中偶发失败
- 错误: NullPointerException at Tip.merge(Tip.java:121)
- 失败率: 0.5% (5次/1000次运行, 平均每22天一次)
- 只在 GitHub Actions 环境中出现，本地无法稳定复现

测试策略（TDD 红色阶段）:
1. shouldReproduceNPEInRunnableParallel (50次重复)
   - 使用 200ms 延迟制造快慢分支，增大竞态窗口
   - 预期：在 GitHub Actions 中应该能偶发触发 NPE

2. shouldReproduceOriginalTestFailure (20次重复)
   - 使用原始测试配置重复运行
   - 预期：在 GitHub Actions 中应该能偶发触发 NPE

验证目标:
- 如果这些测试在 GitHub Actions 中失败（NPE），证明测试有效
- 如果全部通过，需要调整延迟时间或重复次数
- 为后续修复提供可靠的验证基准

下一步:
- 推送到 99.99.x 分支触发 GitHub Actions
- 观察测试结果，确认能够复现 NPE
- 然后添加修复代码，再次验证

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Sonnet 4.5 <[email protected]>

Author: CodeCasterX

framework/fel/java/fel-flow/src/test/java/modelengine/fel/engine/operators/PatternTest.java

@@ -42,6 +42,7 @@
 import modelengine.fitframework.util.StringUtils;
 
 import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
 import java.util.Collection;
@@ -97,6 +98,62 @@ void shouldOkWhenAiFlowWithExampleSelector() {
         assertThat(converse.offer("1+2").await().text()).isEqualTo("2+2=4\n2+3=5\n1+2=");
     }
 
+    @RepeatedTest(50)
+    @DisplayName("【复现测试】强制触发 runnableParallel 的竞态条件 NPE")
+    void shouldReproduceNPEInRunnableParallel() {
+        // 慢分支：模拟 fewShot() 的延迟，增大竞态窗口
+        modelengine.fel.engine.operators.patterns.SyncTipper<String> slowBranch = arg -> {
+            try {
+                Thread.sleep(200);  // 200ms 延迟
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+            return Tip.from("slow", "slow-value");
+        };
+
+        // 快分支：模拟 question() 的快速返回
+        modelengine.fel.engine.operators.patterns.SyncTipper<String> fastBranch = arg -> {
+            return Tip.from("fast", "fast-value");
+        };
+
+        // 执行并发聚合
+        Conversation<String, Prompt> converse = AiFlows.<String>create()
+                .runnableParallel(fastBranch, slowBranch)
+                .prompt(Prompts.human("{{fast}} {{slow}}"))
+                .close()
+                .converse();
+
+        // 在修复前：这里应该偶发抛出 NullPointerException
+        // 在修复后：这里应该稳定通过
+        String result = converse.offer("test").await().text();
+
+        assertThat(result).contains("fast-value", "slow-value");
+    }
+
+    @RepeatedTest(20)
+    @DisplayName("【复现测试】使用原测试配置重复运行")
+    void shouldReproduceOriginalTestFailure() {
+        // 使用原始失败测试的完全相同配置
+        Example[] examples = {new DefaultExample("2+2", "4"), new DefaultExample("2+3", "5")};
+
+        Conversation<String, Prompt> converse = AiFlows.<String>create()
+                .runnableParallel(
+                        question(),
+                        fewShot(ExampleSelector.builder()
+                                .template("{{q}}={{a}}", "q", "a")
+                                .delimiter("\n")
+                                .example(examples)
+                                .build()))
+                .prompt(Prompts.human("{{examples}}\n{{question}}="))
+                .close()
+                .converse();
+
+        // 在修复前：偶发 NPE
+        // 在修复后：稳定通过
+        assertThat(converse.offer("1+2").await().text())
+                .isEqualTo("2+2=4\n2+3=5\n1+2=");
+    }
+
     @Test
     @DisplayName("测试 Retriever")
     void shouldOkWhenAiFlowWithRetriever() {