initParamMap.put(Constants.CRAWLING_INFO_ID, sid);

            final DataCrawlingThread dataCrawlingThread = new DataCrawlingThread(dataConfig, indexUpdateCallback, initParamMap);
            dataCrawlingThread.setPriority(crawlerPriority);
            dataCrawlingThread.setName(sid);
            dataCrawlingThread.setDaemon(true);

            dataCrawlingThreadList.add(dataCrawlingThread);

        }

        // run index update
        final IndexUpdater indexUpdater = ComponentUtil.getIndexUpdater();
        indexUpdater.setName("IndexUpdater");
        indexUpdater.setPriority(indexUpdaterPriority);
        indexUpdater.setSessionIdList(sessionIdList);
        indexUpdater.setDaemon(true);
        indexUpdater.setCrawlerList(crawlerList);

                    buf = null;
                }
            } else if (PRIORITY_ELEMENT.equals(elementName) && buf != null && sitemapUrl != null) {
                sitemapUrl.setPriority(buf.toString().trim());
                buf = null;
            } else if (IMAGE_IMAGE_ELEMENT.equals(elementName)) {
                if (currentImage != null && sitemapUrl != null) {

    // Sleep for enough time to add 1500 milliseconds of overwait to the get() call.
    long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
    Thread.sleep(toWaitMillis);
    thread.setPriority(Thread.MAX_PRIORITY);
    Thread.class.getMethod("resume").invoke(thread);
    thread.join();
    // It's possible to race and suspend the thread just before the park call actually takes effect,

    // Sleep for enough time to add 1500 milliseconds of overwait to the get() call.
    long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
    Thread.sleep(toWaitMillis);
    thread.setPriority(Thread.MAX_PRIORITY);
    Thread.class.getMethod("resume").invoke(thread);
    thread.join();
    // It's possible to race and suspend the thread just before the park call actually takes effect,

pkg syscall (linux-386), func Dup3(int, int, int) error
pkg syscall (linux-386), func Getpriority(int, int) (int, error)
pkg syscall (linux-386), func GetsockoptICMPv6Filter(int, int, int) (*ICMPv6Filter, error)
pkg syscall (linux-386), func GetsockoptIPv6MTUInfo(int, int, int) (*IPv6MTUInfo, error)
pkg syscall (linux-386), func Setpriority(int, int, int) error
pkg syscall (linux-386), func SetsockoptByte(int, int, int, uint8) error

        assertEquals(3, sitemaps.length);
        assertEquals("1.5", ((SitemapUrl) sitemaps[0]).getPriority());
        assertEquals("-0.5", ((SitemapUrl) sitemaps[1]).getPriority());
        assertEquals("abc", ((SitemapUrl) sitemaps[2]).getPriority());
    }

    public void test_parseXmlSitemaps_withInvalidChangefreq() {
        // Invalid changefreq values should be preserved

     * @param scoreBooster The score booster.
     */
    protected void addScoreBooster(final ScoreBooster scoreBooster) {
        scoreBoosterList.add(scoreBooster);
        scoreBoosterList.sort((b1, b2) -> b2.getPriority() - b1.getPriority());
    }

            throws NoRepositoryConnectorException {
        return new TestRepositoryConnector(repository);
    }

    @Override
    public float getPriority() {
        return 0;
    }

                            PhaseId phaseId = PhaseId.of(phase);
                            if (phaseId.priority() == 0) {
                                phaseId = PhaseId.of(phase + "[" + execution.getPriority() + "]");
                            }
                            addMojoExecution(phaseBindings, mojoExecution, phaseId);
                        }
                    }
                }