Différences

Ci-dessous, les différences entre deux révisions de la page.

--- lang:java:thread [2023/05/31 14:32] – Ajout de "Semaphore" root
+++ lang:java:thread [2023/06/12 15:07] (Version actuelle) – Ajout de "Nommage des threads" root
@@ Ligne 34: / Ligne 34: @@
 ''FutureTask'' s'exécute depuis un ''Executor'' et la valeur de retour est récupérée via la méthode bloquante ''get''.
-Quand une exception est générée, elle est transformée en une ''ExecutionException'' lors de l'appel à ''get''.
+Quand une exception est générée, elle n'est pas remontée au thread principale. Elle est transformée en une ''ExecutionException'' qui sera générée lors de l'appel à ''get''.
 <code java>
@@ Ligne 62: / Ligne 62: @@
 }
 </code>
+Sortie standard :
 <code>
@@ Ligne 79: / Ligne 81: @@
 </code>
+Si l'exception doit être remontée au thread principale, il faut créer une classe qui hérite de ''FutureTask'' et surchargée la méthode ''done()'', appeler le ''get()'' avec le try/catch associé et générer une autre exception (''AssertionError'' par exemple).
+<code java>
+import java.io.IOException;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.FutureTask;
+public class MyClass {
+  public static class SecuredFutureTask<V> extends FutureTask<V> {
+    public SecuredFutureTask(Callable<V> callable) {
+      super(callable);
+    }
+    @Override
+    protected void done() {
+      try {
+        get();
+      } catch (ExecutionException | InterruptedException e) {
+        throw new AssertionError(e);
+      }
+    }
+  }
+  public static void main(String args[]) {
+    FutureTask<Void> futureTask =
+        new SecuredFutureTask<Void>(() -> { throw new IOException("OUPS"); });
+    ExecutorService executor = Executors.newFixedThreadPool(2);
+    executor.execute(futureTask);
+    System.out.println("OK");
+    executor.shutdown();
+  }
+}
+</code>
+Sortie standard :
+<code>
+OK
+Exception in thread "pool-1-thread-1" java.lang.AssertionError: java.util.concurrent.ExecutionException: java.io.IOException: OUPS
+	at MyClass$SecuredFutureTask.done(MyClass.java:19)
+	at java.base/java.util.concurrent.FutureTask.finishCompletion(FutureTask.java:381)
+	at java.base/java.util.concurrent.FutureTask.setException(FutureTask.java:250)
+	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:269)
+	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
+	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
+	at java.base/java.lang.Thread.run(Thread.java:833)
+Caused by: java.util.concurrent.ExecutionException: java.io.IOException: OUPS
+	at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122)
+	at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191)
+	at MyClass$SecuredFutureTask.done(MyClass.java:17)
+	... 6 more
+Caused by: java.io.IOException: OUPS
+	at MyClass.lambda$main$0(MyClass.java:25)
+	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
+	... 3 more
+</code>
 =====Accès concurrent=====
 <code java>
@@ Ligne 143: / Ligne 204: @@
 </code>
+=====Debug=====
+====Nommage des threads====
+Par défaut, le nom d'un thread est ''Thread-0'' / ''Thread-1''. Si le thread tourne dans un pool : ''pool-1-thread-1''.
+Dans le cas des threads, cela se fait directement depuis le constructeur.
+<code java>
+new Thread(() -> {}, "Nom du thread").start();
+</code>
+Dans le cas de ''Runnable'' qui se lancent dans un pool de threads, il faut modifier le nom directement dans la méthode exécutée par le thread.
+<code java>
+new FutureTask<>(() -> {
+  Thread.currentThread().setName("Nom du thread");
+});
+</code>