Не удается остановить задачу, которая запускается с помощью ExecutorService - PullRequest
Новая
       4

Не удается остановить задачу, которая запускается с помощью ExecutorService

3 голосов
/ 26 декабря 2011

Извините, я должен открыть новую тему, чтобы описать эту проблему.

Сегодня утром я задал этот вопрос , есть ответы, но моя проблема все еще не решена.

На этот раз я приложу некоторый исполняемый код (упрощенный, но с той же проблемой), чтобы вы воспроизвели проблему: 

public class ThreadPoolTest {
    public static void main(String[] args) throws Exception {
        final ExecutorService taskExecutor = Executors.newFixedThreadPool(5);
        Future<Void> futures[] = new Future[5];
        for (int i = 0; i < futures.length; ++i)
            futures[i] = startTask(taskExecutor);

        for (int i = 0; i < futures.length; ++i)
            System.out.println("futures[i].cancel(true): " + futures[i].cancel(true));

        System.out.println("Cancel DONE.");
        taskExecutor.shutdown();
    }

    private static Future<Void> startTask(final ExecutorService taskExecutor) {
        Future<Void> f = taskExecutor.submit(new Callable<Void>() {
            public Void call() throws Exception {
                try {
                    downloadFile(new URI("http://stackoverflow.com"));
                    while(true) {
                        System.out.println(Thread.currentThread().getName() + ": " + Thread.currentThread().isInterrupted());
                        if(Thread.currentThread().isInterrupted())
                            break;
                    }
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
                return null;
            } 
        });
        return f;
    }

    private static void downloadFile (final URI uri) throws Exception {
//        if(true) return;
        Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
        return;
    }
}

Приведенный выше код, скорее всего, будет пойман в бесконечный цикл (вы можете захотеть запустить код несколько раз, чтобы увидеть то, что я видел), как вы можете видеть в основном методе, который я назвал futures [i] .cancel (true) для всех задач, я не знаю, почему это происходит, это мучает меня больше суток.

Ваша помощь будет принята с благодарностью.

Ответы [ 3 ]

6 голосов
/ 26 декабря 2011

Я играл с вашим кодом и заметил, что состояние прерывания потока иногда имеет значение true перед созданием сокета и false после.

Я попытался прервать поток и вызвать конструктор Socket, и поток всегда остается прерванным после этого.Я также попытался удалить отключение пула потоков, и проблема продолжала возникать.

Тогда я попытался использовать 5 разных URI, а не всегда один и тот же.И проблема никогда не случалась.

Итак, я написал эту простую программу, показывающую, что пул потоков не виновник, а сокет: 

public static void main(String[] args) throws Exception {
    final URI uri = new URI("http://stackoverflow.com");
    for (int i = 0; i < 5; i++) {
        Runnable r = new Runnable() {
            @Override
            public void run() {
                Thread.currentThread().interrupt();
                System.out.println(Thread.currentThread().isInterrupted());
                try {
                    Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
                }
                catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().isInterrupted());
            }
        };
        new Thread(r).start();
    }
}

И действительно, когда 5 потоков создают сокет для одного хостаи порт, у 4 из них статус прерывания очищен.

Затем я попытался синхронизировать создание сокета (с одной блокировкой, но я полагаю, вы можете использовать одну блокировку на хост / порт): 

synchronized(lock) {
    try {
        Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
    }
    catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

и ТАДА ... проблема исчезла.Я бы открыл ошибку в Oracle, чтобы сигнализировать о проблеме.

0 голосов
/ 26 декабря 2011

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

for (int i = 0; i < futures.length; ++i)
      futures[i] = startTask(taskExecutor);
Thread.sleep(100);
for (int i = 0; i < futures.length; ++i)
     System.out.println("futures[i].cancel(true): " + futures[i].cancel(true));

и все было отменено.

0 голосов
/ 26 декабря 2011

Я запустил ваш код, и он не остановился, как вы сказали.

У меня не было много времени, чтобы выяснить, почему он так себя ведет, но я обнаружил, что объявление потоков службы-исполнителя в качестве демоновзаставил проблему уйти: 

private static ExecutorService TaskExecutor = Executors.newFixedThreadPool(5, new ThreadFactory() {
    public Thread newThread(Runnable r) {
        Thread t = new Thread(r);
        t.setDaemon(true);
        return t;
    }
});

Я вернусь, если найду лучшее объяснение.

...