Java appel de méthode asynchrone

J'ai déjà un thread qui a aux travaux suivants:

public class DetectionHandler extends TimerTask {

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

Je voudrais que la numérisation d'être parallèles. Donc je suppose que je dois les appeler que deux méthodes de façon asynchrone. Et lorsque la numérisation est terminée, alors je peux continuer à travailler dans DetectionHandler classe.

J'ai essayé de la façon que BluetoothModule et WiFiModule implements Runnable mais pas eu de chance. Tnx

OriginalL'auteur vale4674 | 2010-10-23

  1. 4

    À l'aide de ExecutorService vous pouvez écrire quelque chose comme ceci:

    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);

    OriginalL'auteur Eugene Kuleshov

  2. 3

    Obtenir un ExecutorService de Les exécuteurs et de lui donner un FutureTask.

    Vous pouvez ensuite attendre les résultats en appelant le blocage get() sur le retour de l'Avenir. Les analyses parallèles, mais votre méthode run (montré ici) va encore attendre pour les scans d'être terminé.

    Un peu comme:

         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

    Attention cependant, obtenir va retourner tout appel renvoie. Les Exceptions sont enveloppés dans une ExecutionException.

    tnak vous: je l'ai fait comme ceci particule.kth.se/~lindsey/JavaCourse/Livre/Part1/Java/Chapter10/...
    Si vous décidez de jouer avec les fils et démarrer le partage de données entre les threads, je heartilly recommandons javaconcurrencyinpractice.com (le livre). À l'aide de threads peut avoir des résultats étranges lorsqu'il n'est pas prudent. Pas un problème dans ce cas, bien sûr.

    OriginalL'auteur extraneon