Несколько тем в Java

Question

У меня есть класс. Например:

public class Data { 
    private String name; 

    public Data(String url) { 
     // There is download something from the Internet and set field "name". 
    } 

    public String getName() { 
     return name; 
    } 
} 

В некотором методе мне нужно инициализировать массив объектов Data.

ArrayList<Data> list = new ArrayList<Data>; 
for(int i=0; i<max; i++) { 
    list.add(new Data("http://localhost/" + String.valueOf(i))); 
} 

Но оно длинное. Я хочу сделать это:

final ArrayList<Data> list = new ArrayList<Data>; 
for(int i=0; i<max; i++) { 
    final int tmp = i; 
    new Thread() { 

     public void run() { 
      list.add(new Data("http://localhost/" + String.valueOf(tmp))); 
     } 

    }.start(); 

} 

Но основная тема заканчивается раньше остальных, а список переменных пуст. Что мне делать? Помощь pls:

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

Answer 1

Вместо того, чтобы дело с деталями низкого уровня API Thread, вы можете использовать параллельный пакет Java, с исполнителем для обработки нити (я не знаю, какие ListArray есть, но если он не является потокобезопасным, у вас возникнут проблемы с предлагаемым решением, некоторые из других ответов: добавление соединения будет недостаточным).

Например, упрощенный пример будет:

final ExecutorService executor = Executors.newFixedThreadPool(10); 
final List<Future<Data>> list = new ArrayList<Future<Data>>(max); 

for (int i = 0; i < max; i++) { 
    final int tmp = i; 
    Callable<Data> c = new Callable<Data>() { 
     @Override 
     public Data call() { 
      return new Data("http://localhost/" + tmp); 
     } 
    }; 
    list.add(executor.submit(c)); 
} 

executor.shutdown(); 

for (Future<Data> future : list) { 
    Data data = future.get(); //will block until the page has been downloaded 
    //use the data 
} 

В идеале, вы whould добавить обработку ошибок вокруг future.get(), так как он будет бросать ExecutionException, если ваша задача генерирует исключение, которое я полагаю может произойти, если например, страница недоступна.

Answer 2

1. Когда вы запускаете Другой поток, который выполняет работу по получению данных из сети и заполнению списка, сразу после этого использует метод join().

2.join() метод не будет препятствовать следующей строке выполнить до того, как метод нити, на которой он называетсяrun()имеет отделку().

3. Таким образом, ваш метод main() не будет выполняться до того, как список заполняется, как вы использовали join() держать исполнение до другого потока делаются .....

Answer 3

В главном использовании Thread.join ждать дочерних потоков для завершения

Thread[] threads = new Thread[max]; 
    final List<Data> list = Collections.synchronizedList(new ArrayList<Data>()); 
    for(int i=0; i< max; i++) { 
     final int tmp = i; 
     Thread t = new Thread() { 

      public void run() { 
       list.add(new Data("http://localhost/" + String.valueOf(tmp))); 
      } 

     }; 
     t.start(); 
     threads[i] = t; 
    } 
    for (Thread t : threads) { 
     t.join(); 
    }