Почему SocketTimeoutException заставляет мою программу замерзать?

Question

Я передаю свою программу более чем 600 ссылкам, хранящейся в ArrayList, чтобы получить название веб-страницы, используя JSoup (среди прочих). Для каждой ссылки (используя для цикла) я создаю новый поток (используя thread.start()) и передаю ссылку через мою программу, я жду, пока мой поток завершится (с thread.join) перед запуском нового потока (одновременное выполнение вызовет некоторые проблемы, я сделал это, чтобы предотвратить неожиданный конец потока, чтобы остановить выполнение для других ссылок).

Проблема в том, что иногда JSoup выбрасывает исключение SocketTimeoutException (которое я должен уловить), что заставляет меня замораживать мою программу. Я не знаю, почему выполнение останавливается даже в окружении try/catch.

Вот часть моего кода, возможно, может помочь вам понять:

// In the method actionPerformed() of my JPanel 

for(final String link : links) 
{ 
    Thread t = new Thread() 
    { 
     public void run() 
     { 
      Analyzer.process(link); 
     } 
    }; 
    t.start(); 
    try 
    { 
     t.join(); 
    } 
    catch (InterruptedException e) 
    { 
     e.printStackTrace(); 
    } 
} 

И в моем процессе:

// method process() of my Analyzer class 
try 
{ 
    Document doc = Jsoup.connect(lien).userAgent("Mozilla").timeout(5*10000).get(); 
    //     ^EXCEPTION THROWN HERE !^

    title = doc.title(); 
} 
catch (Exception e) 
{ 
    e.printStackTrace(); 
    erreurs+="Erreur lors de la lecture du titre\n"; 
} 

Это раздражает, потому что процесс ооочень долго, я смочите на ночь, и найти сегодня, что моя программа застыла на 54-й ссылке. ^^ 'Спасибо заранее!

EDIT - ОБНОВЛЕНИЕ

SercanOzdemir предложил мне использовать ExecutorService, вместо того чтобы создавать темы и сделать старт() - Join(), так что я пробовал:

ExecutorService ex = Executors.newSingleThreadExecutor(); 
for(final String link : links) 
{ 
    System.err.println("-- "+i+" --");    //DEBUG 
    ex.execute(new Runnable(){ 
      @Override 
      public void run(){ 
       try 
       { 
        Analyzer.process(link); 
       } 
       catch(Exception e) 
       { 
        e.printStackTrace(); 
       } 

      } 
    }); 
    i++;           //DEBUG 
    } 
ex.shutdown(); 

Но он печатает только мой отладочные ссылки. Любая идея, почему он не запускает мой процесс?

Answer 1

Я не пробовал это с помощью jsoup, но это простой способ создания потоков для выполнения задачи и контроля их состояния.

ExecutorService executorService = Executors.newCachedThreadPool(); 
    Future future = null; 
    for(final String link : links) 
    { 
     future = executorService.submit(new Runnable(){ 

     @Override 
     public void run(){ 
      try{ 
       Analyzer.process(link); 
      } 
      catch(Exception e){ 
       e.printStackTrace(); 
      } 

     } 
    }); 

     while(future != null 
       && !future.isDone() 
       && !future.isCancelled()) 
     { 
      try { 
       Thread.sleep(2000); // Or do something else 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
     } 

    } 

    executorService.shutdown(); 

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

ExecutorService ex = Executors.newSingleThreadExecutor(); 
for(final String link : links) 
{ 
    System.err.println("-- "+i+" --");    //DEBUG 
    ex.execute(new Runnable(){ //Here it is created 
     @Override 
     public void run(){ 
      try 
      { 
       Analyzer.process(link); 
      } 
      catch(Exception e) 
      { 
       e.printStackTrace(); 
      } 

     } 
}); 
i++;           //DEBUG 
//a split second later this loop finishes and overwrites the service again 
} 
ex.shutdown(); 

Answer 2

Открытие новой темы для каждой ссылки - очень плохой вариант.

Рассмотрите возможность использования ExecutionService, если вы хотите использовать программу с несколькими потоками.

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

new Runnable(){ 

      @Override 
      public void run(){ 
       try{ 
        // your codes 
       } 
       catch(Exception e){ 
        e.printStackTrace(); 
       } 

      } 
     }.run();