Java асинхронный вызов метода

Question

Я уже один поток, который должен выполнить следующие работы:

public class DetectionHandler extends TimerTask { 

@Override 
public void run() { 
bluetoothAddresses = BluetoothModule.scanAddresses(); 
wiFiAddresses = WiFiModule.scanAddresses(); 
...//when scanning is finished, continue work 
} 

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

Я пробовал, как BluetoothModule и WiFiModule реализует Runnable, но не повезло. Tnx

Answer 1

Использование ExecutorService вы можете написать что-то вроде этого:

ArrayList<Callable<Collection<Address>>> tasks = new ArrayList<Callable<Collection<Address>>>(); 
tasks.add(new Callable<Collection<Address>>() { 
    public Collection<Address> call() throws Exception { 
    return BluetoothModule.scanAddresses(); 
    } 
}); 
tasks.add(new Callable<Collection<Address>>() { 
    public Collection<Address> call() throws Exception { 
    return WiFiModule.scanAddresses(); 
    } 
}); 

ExecutorService executorService = Executors.newFixedThreadPool(2); 
List<Future<Collection<Address>>> futures = executorService.invokeAll(tasks); 

Answer 2

Получить Исполнительный аппарат от Executors и дать ему FutureTask.

Вы можете дождаться результатов, вызвав блокировку get() в возвращаемом Будущем. Сканирование будет выполняться параллельно, но ваш метод запуска (показанный здесь) будет по-прежнему ждать завершения сканирования.

Немного напоминает:

 FutureTask<List<Address>> btFuture = 
     new FutureTask<List<Address>>(new Callable<List<Address>>() { 
     public List<Address> call() { 
      return BluetoothModule.scanAddresses(); 
     }}); 
    executor.execute(btFuture); 

    FutureTask<List<Address>> wfFuture = 
     new FutureTask<List<Address>>(new Callable<List<Address>>() { 
     public List<Address> call() { 
      return WifiModule.scanAddresses(); 
     }}); 
    executor.execute(wfFuture); 

    btAddresses = btFuture.get(); // blocks until process finished 
    wifiAddresses = wfFuture.get(); // blocks 

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