Java ScheduledThreadPoolExecutor: Можно ли выполнить Runnables в списке после shutdownNow ()? - PullRequest
Новая
       8

Java ScheduledThreadPoolExecutor: Можно ли выполнить Runnables в списке после shutdownNow ()?

0 голосов
/ 30 мая 2018

Я не могу выполнить Runnables (отложенные задачи в очереди), которые были возвращены в списке Runnables после вызова shutdownNow () для объекта ScheduledThreadPoolExecutor.

Я пробовал несколько способов сделать это: вы можете получить размер списка, один из самих объектов Runnable, вызвать запрос isDone (), но я не справился, чтобы запустить их.

МОГУТ ли они быть выполнены и КАК, если возможно?

См. Пожалуйста код ниже.Спасибо. 

import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadPoolExecutor;

public class ExecuteExisitingDelayedTasksAfterShutdownPolicy1 {
private static int count = 0;

private static class Task implements Runnable {
    private String name;

    public Task(String name) {
        this.name = name;
        count++;
    }

    @Override
    public void run() {
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            return;
        }
        System.out.printf("\n%s: " + getName(), Thread.currentThread().getName());
    }

    public String getName() {
        return name;
    }
}

public static void main(String[] args) throws InterruptedException, ExecutionException {
    ScheduledThreadPoolExecutor stpe = new ScheduledThreadPoolExecutor(10, new ThreadPoolExecutor.DiscardPolicy());
    stpe.setExecuteExistingDelayedTasksAfterShutdownPolicy(true);
    List<Runnable> queue = null;
    for (int i = 0; i < 100; i++) {
        stpe.execute(new Task("Task " + count));
        if (i == 50) {
            Thread.sleep(1000);
            queue = stpe.shutdownNow();
            System.out.print("\nQueue SIZE: " + queue.size());
        }
    }
    Thread.sleep(3000);
    System.out.print("\n" + queue.get(0));
    @SuppressWarnings("unchecked")
    FutureTask<Task> ftask = (FutureTask<Task>) queue.get(0);
    ExecutorService ses = Executors.newSingleThreadExecutor();
    /**
     * all of the next.. doesn't work: tasks returned in a queue are likely 
    to be
     * unrunnable
     */
    ftask.get().run();
    System.out.println(ftask.get().name);
    ses.execute(ftask);
    queue.get(0).run();

   }
}
...