java ScheduledFuture getDelay возвращает отрицательное значение

Question

java ScheduledFuture getDelay возвращает отрицательное значение

Я собрал два разных ответа:

Ограничить символы

Полный HTML теги, отсутствующие

$string = strip_tags($strHTML);
$yourText = $strHTML;
if (strlen($string) > 350) {
    $stringCut = substr($post->body, 0, 350);
    $doc = new DOMDocument();
    $doc->loadHTML($stringCut);
    $yourText = $doc->saveHTML();
}
$yourText."...<a href=''>View More</a>"

0

java semaphore scheduledexecutorservice

задан MIT 2 March 2019 в 11:32

2 ответа

Другие вопросы по тегам:

java semaphore scheduledexecutorservice

Похожие вопросы:

score 0 · Answer 1

scheduler.schedule() - функция однократного включения, поэтому она показывает отрицательное значение getDelay().

score 0 · Answer 2

Если задание выполнено, getDelay(TimeUnit) будет отрицательным. Чтобы показать это, я добавляю два параметра в scheduleReplenishment() и изменяю getReplenishmentTime() на printReplenishmentTime().

Примечание 1: Если вы создаете Future<> и заменяете одно другим, вам следует позаботиться об удаленном ...

Примечание 2: Если вы хотите проверить Future<> и Semaphore, не высвобождайте выделенные ресурсы немедленно.

private final ConcurrentSkipListMap<String, ScheduledFuture<?>> scheduledFutures
                                    = new ConcurrentSkipListMap<>();
private final AtomicInteger counter = new AtomicInteger();

public void printReplenishmentTime() {

    scheduledFutures.forEach((name, f) -> {

        final long delay = f.getDelay(TimeUnit.SECONDS);
        System.out.println(name + " delay " + delay);
    });
}

/**
 * try acquire one permit once from {@code semaphore}, 
 * then wait {@code waitInMillis}, until all permits used.
 * 
 * @param waitInMillis after successfully used one permit, wait
 * @param permits all permits to use, best if permits @gt; 2
 */
public void scheduleReplenishment(final long waitInMillis, final int permits) {

    final String name = "future" + counter.getAndIncrement();
    scheduledFutures.put(name, scheduler.schedule(() -> {

        try {

            for (int permit = permits; 0 < permit;) {

                final boolean ack = semaphore.tryAcquire(1);
                System.out.println(name + " " + (ack ? "acquire" : "not acquire")
                        + " one, but need " + permit);
                if (ack) {

                    permit--;
                }
                if (0 < permit) {

                    try {
                        Thread.sleep(waitInMillis);
                    } catch (final InterruptedException e) {

                        System.out.println(name + " interrupted, exiting...");
                        return;
                    }
                }
            }
            System.out.println(name + " done");

        } finally {

            semaphore.release(permits - permit);
        }

        // BAD CODE: semaphore.availablePermits() for debugging purposes
        // only, maybe 0 release...
        // semaphore.release(permits - semaphore.availablePermits());
    }, durationInMillis, TimeUnit.MILLISECONDS));
}