Как завершить поток в службе-исполнителе, если поток занимает слишком много времени?

Как я могу завершить задачу потока, если он не подключается к серверу в течение 2 секунд.

Обычно это сложно сделать, потому что даже если вы прервете поток (как упоминается в других ответах), нет гарантии, что поток остановится. Прерывание просто устанавливает флаг в потоке, и код должен определить состояние и остановить. Это означает, что тонны потоков могут находиться в фоновом режиме в ожидании соединений.

Однако в вашем случае вы используете метод ch.ethz.ssh2.Connection.connect(). Оказывается, есть метод подключения, требующий таймаута. Я думаю, вы хотите следующее:

// try to connect for 2 seconds
conn.connect(null, 2000, 0);

Цитата из подключить метод javadocs:

В случае тайм-аута (либо connectTimeout, либо kexTimeout) генерируется исключение SocketTimeoutException.

Вы должны сначала выполнить awaitTermination(), затем проверить возвращаемое значение, а затем выполнить shutdownNow(). shutdown() не гарантирует мгновенную остановку службы, он просто прекращает принимать новые задания и ожидает завершения всех заданий по порядку. shutdownNow(), с другой стороны, прекращает принимать новые задания, активно пытается остановить все запущенные задачи и не запускает новые, возвращая список всех заданий, ожидающих выполнения.

Из JavaDocs:

Следующий метод завершает работу ExecutorService в два этапа: сначала вызывается shutdown, чтобы отклонить входящие задачи, а затем, если необходимо, вызывается shutdownNow, чтобы отменить любые зависшие задачи:

 void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); // Disable new tasks from being submitted
   try {
     // Wait a while for existing tasks to terminate
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); // Cancel currently executing tasks
       // Wait a while for tasks to respond to being cancelled
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     // (Re-)Cancel if current thread also interrupted
     pool.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }
 }

Вы всегда можете вызвать future.get(timeout...) Он вернет исключение тайм-аута, если он еще не закончился... тогда вы можете вызвать future.cancel().

Пока вы имеете дело с потоками в Java, единственный безопасный способ остановить поток — прервать его. Вы можете сначала позвонить shutdown(), а затем подождать. Этот метод не прерывает потоки.

Если это не помогает, вы вызываете shutdownNow(), который пытается отменить задачи, устанавливая флаг прерывания каждого потока в значение true. В этом случае, если потоки заблокированы/ожидают, будет выдано InterruptedException. Если вы проверите флаг прерывания где-то внутри своих задач, то у вас тоже все хорошо.

Но если у вас нет другого выбора, кроме как остановить потоки, вы все равно можете это сделать. Одним из возможных решений получения доступа к воркерам является трассировка всех созданных потоков внутри ThreadPoolExecutor с помощью собственной фабрики потоков.

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class TestThreadPoolEx {

    static class CustomThreadFactory implements ThreadFactory {
        private List<Thread> threads = new ArrayList<>();

        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r);
            threads.add(t);
            return t;
        }

        public List<Thread> getThreads() {
            return threads;
        }

        public void stopThreads() {
            for(Thread t : threads) {
                if(t.isAlive()) {
                    try {
                        t.stop();
                    } catch (Exception e) {
                        //NOP
                    }
                }
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
        CustomThreadFactory factory = new CustomThreadFactory();
        ExecutorService ex = Executors.newFixedThreadPool(1, factory);
        ex.submit(() -> {
            while(true);
        });
        ex.shutdown();
        ex.awaitTermination(5, TimeUnit.SECONDS);
        ex.shutdownNow();
        ex.awaitTermination(5, TimeUnit.SECONDS);
        factory.stopThreads();
    }
}

Это, безусловно, небезопасно, но должно соответствовать вашим требованиям. В этом случае он может остановить цикл while(true). Отмена задач не сможет этого сделать.