assertEquals("All lines should be processed", 5000, receivedLines.size());
        assertEquals("First line", "Line number 0", receivedLines.get(0));
        assertEquals("Last line", "Line number 4999", receivedLines.get(4999));
    }

    @Test
    public void test_run_concurrentAccess() throws InterruptedException {
        String input = "concurrent1\nconcurrent2\nconcurrent3";

        assertNull(dataconfigpager.versionNo);

        assertEquals(1, dataconfigpager.getDefaultCurrentPageNumber());
        dataconfigpager.setAllRecordCount(999);
        assertEquals(999, dataconfigpager.getAllRecordCount());
        dataconfigpager.setAllPageCount(999);
        assertEquals(999, dataconfigpager.getAllPageCount());
        dataconfigpager.setExistPrePage(true);
        assertTrue(dataconfigpager.isExistPrePage());

        assertNull(reqHeaderPager.name);
        assertNull(reqHeaderPager.versionNo);

        reqHeaderPager.setAllRecordCount(999);
        assertEquals(999, reqHeaderPager.getAllRecordCount());
        reqHeaderPager.setAllPageCount(999);
        assertEquals(999, reqHeaderPager.getAllPageCount());
        reqHeaderPager.setExistPrePage(true);
        assertTrue(reqHeaderPager.isExistPrePage());

        assertNull(webConfigPager.name);
        assertNull(webConfigPager.versionNo);

        webConfigPager.setAllRecordCount(999);
        assertEquals(999, webConfigPager.getAllRecordCount());
        webConfigPager.setAllPageCount(999);
        assertEquals(999, webConfigPager.getAllPageCount());
        webConfigPager.setExistPrePage(true);
        assertTrue(webConfigPager.isExistPrePage());

        assertNull(failureUrlPager.errorCount);
        assertNull(failureUrlPager.errorName);

        failureUrlPager.setAllRecordCount(999);
        assertEquals(999, failureUrlPager.getAllRecordCount());
        failureUrlPager.setAllPageCount(999);
        assertEquals(999, failureUrlPager.getAllPageCount());
        failureUrlPager.setExistPrePage(true);
        assertTrue(failureUrlPager.isExistPrePage());

        assertNull(fileAuthPager.fileConfigId);
        assertNull(fileAuthPager.versionNo);

        fileAuthPager.setAllRecordCount(999);
        assertEquals(999, fileAuthPager.getAllRecordCount());
        fileAuthPager.setAllPageCount(999);
        assertEquals(999, fileAuthPager.getAllPageCount());
        fileAuthPager.setExistPrePage(true);
        assertTrue(fileAuthPager.isExistPrePage());

        assertNull(badwordpager.versionNo);

        assertEquals(1, badwordpager.getDefaultCurrentPageNumber());
        badwordpager.setAllRecordCount(999);
        assertEquals(999, badwordpager.getAllRecordCount());
        badwordpager.setAllPageCount(999);
        assertEquals(999, badwordpager.getAllPageCount());
        badwordpager.setExistPrePage(true);
        assertTrue(badwordpager.isExistPrePage());

        assertNull(stemmerOverridePager.id);

        stemmerOverridePager.setAllRecordCount(999);
        assertEquals(999, stemmerOverridePager.getAllRecordCount());
        stemmerOverridePager.setAllPageCount(999);
        assertEquals(999, stemmerOverridePager.getAllPageCount());
        stemmerOverridePager.setExistPrePage(true);
        assertTrue(stemmerOverridePager.isExistPrePage());

        assertNull(relatedQueryPager.term);
        assertNull(relatedQueryPager.versionNo);

        relatedQueryPager.setAllRecordCount(999);
        assertEquals(999, relatedQueryPager.getAllRecordCount());
        relatedQueryPager.setAllPageCount(999);
        assertEquals(999, relatedQueryPager.getAllPageCount());
        relatedQueryPager.setExistPrePage(true);
        assertTrue(relatedQueryPager.isExistPrePage());

        assertNull(schedulerPager.name);
        assertNull(schedulerPager.versionNo);

        schedulerPager.setAllRecordCount(999);
        assertEquals(999, schedulerPager.getAllRecordCount());
        schedulerPager.setAllPageCount(999);
        assertEquals(999, schedulerPager.getAllPageCount());
        schedulerPager.setExistPrePage(true);
        assertTrue(schedulerPager.isExistPrePage());