Comment tester unitairement un extrait de code exécuté à l'intérieur du service d'exécution, au lieu de Thread.sleep (time)

Question

Comment tester un code qui s'exécute dans le service d'exécution? Dans ma situation,

public void test() { 
    Runnable R = new Runnable() { 
     @Override 
     public void run() { 
      executeTask1(); 
      executeTask2(); 
     } 
    }; 

    ExecutorService executorService = Executors.newSingleThreadExecutor(); 
    executorService.submit(R); 
} 

Quand je suis test unitaire, je voudrais faire quelques validations cette méthode est exécutée.

Je l'exécute dans un service d'exécuteur, car il effectue certaines opérations réseau.

Lors de mes tests unitaires, j'ai dû attendre que cette méthode soit terminée. Y at-il une meilleure façon de le faire, au lieu d'attendre Thread.sleep(500).

Unité extrait de code de test:

@Test 
public void testingTask() { 
    mTestObject.test(); 
    final long threadSleepTime = 10000L; 
    Thread.sleep(threadSleepTime); 
    verify(abc, times(2)) 
      .acquireClient(a, b, c); 
    verify(abd, times(1)).addCallback(callback); 
} 

Note: Je passe un objet de service exécuteur testamentaire dans cette catégorie constructeur. Je voudrais savoir s'il y a une bonne façon de tester au lieu d'attendre le temps de sommeil.

Answer 1

Vous pouvez utiliser l'instance Future renvoyée par executorService.submit (R).

De la documentation:

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#submit(java.lang.Runnable)

Soumet une tâche Runnable pour l'exécution et retourne un avenir représentant cette tâche. La méthode get du Future renverra null une fois terminée avec succès.

Answer 2

Quelques possibilités:

• extraire le code de service de l'exécuteur et le tester « autonome » par exemple dans votre exemple test de executeTask1() et executeTask2() eux-mêmes ou encore ensemble, mais tout simplement pas en exécutant eux dans un fil séparé. Le fait que vous « faire passer un objet de service exécuteur testamentaire dans cette catégorie constructeur » aide ici puisque vous pourriez avoir

  • Un test qui se moque du service de l'exécuteur et vérifie que vous soumettez le bon runnable à elle
  • Test (s) qui vérifient le comportement de executeTask1() et executeTask2() sans les exécuter dans un thread séparé.

• Utilisez un CountDownLatch pour permettre à votre code en exécutant service pour indiquer au fil de test quand il est fini. Par exemple:

  // this will be initialised and passed into the task which is run by the ExecutorService 
  // and will be decremented by that task on completion 
  private CountDownLatch countdownLatch; 
  
  @Test(timeout = 1000) // just in case the latch is never decremented 
  public void aTest() { 
      // run your test 
  
      // wait for completion 
      countdownLatch.await(); 
  
      // assert 
      // ... 
  } 
  

• Accepter que vous devez attendre que l'autre fil pour remplir et cacher la laideur des Thread.sleep appels dans vos cas de test en utilisant Awaitility. Par exemple:

  @Test 
  public void aTest() { 
      // run your test 
  
      // wait for completion 
      await().atMost(1, SECONDS).until(taskHasCompleted()); 
  
      // assert 
      // ... 
  } 
  
  private Callable<Boolean> taskHasCompleted() { 
      return new Callable<Boolean>() { 
       public Boolean call() throws Exception { 
        // return true if your condition has been met 
        return ...; 
       } 
      }; 
  }