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());

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

        assertNull(boostdocpager.createdTime);
        assertNull(boostdocpager.versionNo);

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

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

        assertNull(jobLogPager.target);
        assertNull(jobLogPager.scriptType);

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