assertNull(exceptions[i], "Thread " + i + " threw exception");
        }

        // Verify all readers completed all iterations
        for (int i = 0; i < readerCount; i++) {
            assertEquals("Reader " + i + " should complete all iterations", iterations, trueCount[i] + falseCount[i]);
        }
    }

    /**

### Existing properties in existing classes

Prefer either:
  * Provide only non-nullable version and move the `null` check to the call site (if the number of nullable callsites is low).
  * Provide two overloads with a different names (as Java doesn't support overloading on nullability). See 

            }
        };

        // First call should load
        String[] names = testFactory.getDataStoreNames();
        assertEquals(2, names.length);
        assertEquals("Store1", names[0]);
        assertEquals("Store2", names[1]);
        assertEquals(1, loadCount[0]);

        // Second immediate call should use cache
        names = testFactory.getDataStoreNames();

        // First call without SAStruts.method
        mockRequest.setQueryString("query=test");
        assertEquals(customPath, webApiRequest.getServletPath());

        // Second call with SAStruts.method
        mockRequest.setQueryString("SAStruts.method=execute");
        assertEquals(originalPath, webApiRequest.getServletPath());

        // Third call without SAStruts.method again

        description =
            "Command line option for the performance test task to enable profiling. " +
                "For example `async-profiler`, `async-profiler-heap`, `async-profiler-wall`, `async-profiler-all` or `jfr`. Use `none` for benchmarking only.",
    )
}

object AdHocPerformanceScenarioLinux : AdHocPerformanceScenario(Os.LINUX)

        history.add(LlmMessage.user("How to install Fess?"));
        history.add(LlmMessage.assistant("You can install Fess using Docker."));
        final LlmChatRequest request = client.testBuildIntentRequest("Tell me more about Docker", history);
        final List<LlmMessage> messages = request.getMessages();
        // system + 2 history + user = 4 messages
        assertEquals(4, messages.size());

        JsonMappingOption option3 = provider.provideMappingOption();

        // All should be different instances
        assertNotSame(option1, option2);
        assertNotSame(option2, option3);
        assertNotSame(option1, option3);

        // But all should have the same configuration
        assertEquals(option1.getFieldNaming().get(), option2.getFieldNaming().get());

hroughHooksRespectAsync.has(s))return(async()=>{let d=await o.call(i,p);return u.call(i,d)})();let c=o.call(i,p);return u.call(i,c)}:i[a]=(...p)=>{if(this.defaults.async)return(async()=>{let d=await o.apply(i,p);return d===!1&&(d=await u.apply(i,p)),d})();let c=o.apply(i,p);return c===!1&&(c=u.apply(i,p)),c}}r.hooks=i}if(n.walkTokens){let i=this.defaults.walkTokens,s=n.walkTokens;r.walkTokens=function(a){let o=[];return o.push(s.call(this,a)),i&&(o=o.concat(i.call(this,a))),o}}this.defaults={......

                } catch (Exception e) {
                    hasError.set(true);
                }
            });
        }

        // Start all threads
        for (Thread thread : threads) {
            thread.start();
        }

        // Wait for all threads to complete
        for (Thread thread : threads) {
            thread.join(5000); // 5 second timeout
        }