Почему моя многопоточная задача не работает так, как должна?

Question

Я пытаюсь получить сообщения из facebook с помощью пакетных операций. Я думал о том, чтобы сделать эту задачу многопоточной, чтобы ускорить работу. в основном, им отправляет пакетные запросы в facebook и, ожидая ответа, моя задача выполняет другие действия, которые необходимо выполнить. , когда я отлаживаю задачу (медленно), я получаю результаты 2000, которые хочу получить для теста .... , но когда я запускаю его или позволяю ему отлаживать и приостанавливать после операции запроса, он становится меньше 2000.

String[] str = new String[2000]; 
    ExecutorService exec = Executors.newFixedThreadPool(10); 
    List<BatchRequest> request= new CopyOnWriteArrayList<BatchRequest>(); 
    List <BatchResponse> batchResponses = new ArrayList<BatchResponse>(); 



    int i=1; 
    for(int j=0 ; j<2000; j++) { 

     if (i < 50) { 
      BatchRequest batch = new BatchRequestBuilder(str[i]).build(); 
      request.add(batch); 
      i++; 
      counter++; 
     } else { 
      i = 1; 
      exec.execute(new Runnable() { 

       //thread that gets information from facebook into a list of responses 
       public void run() { 
        // TODO Auto-generated method stub 
        System.out.println("running"); 
        batchResponses.addAll(fc.executeBatch(request)); 
        System.out.println("done"); 

       } 

      }); 
      request.clear(); 
     } 
    } 
    exec.shutdown(); 
    exec.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); 

Я удалил все, что не нужно. надеюсь, что это все еще имеет смысл.

Что случилось с моим кодом?

EDIT: ive отредактировал код, чтобы иметь больше смысла. кто угодно?

Answer 1

Похоже, что существует некоторая путаница в коде между counter и i. Возможно, если вы объясните, почему вам нужно, чтобы обе эти вещи стали более ясными.

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

Answer 2

В дополнение к ответу @OldCurmudgeon я могу сказать, что ArrayList не является потокобезопасным классом. Вы можете использовать другой контейнер, обернуть его Collections.synchronizedList() или добавить синхронизацию с вашим кодом.

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

Answer 3

Некоторые проблемы: BatchRonsponses осуществляется через резьбу, а также вы вставляете ее в основной поток. Также batchResponses не является потокобезопасным, поэтому его необходимо синхронизировать.

Также вы делаете request.clear в основной теме ... Это ошибка, поскольку вы не можете гарантировать, что новый поток выполнил, может быть, если новый поток запускается после того, как вы его очистили. И новый поток увидит request.size (0) = 0.

Основной блок if и block имеет тот же код потока, который немного запутан. if (i == 50) вы получаете в блоке и выполняете запросы. , когда ваш счетчик равен 500, вы уже посетили блок else 10 раз, чтобы у вас может быть пустой запрос или последние 50, которые вы вставили.

В этом коде не указано.