}

    /**
     * Test cache refresh mechanism with concurrent access.
     * Verifies that cache is refreshed correctly even with concurrent readers.
     */
    @Test
    public void test_cacheRefresh_withConcurrentReads() throws Exception {
        final int[] loadCount = { 0 };
        final DataStoreFactory testFactory = new DataStoreFactory() {
            @Override