diff --git a/src/impl/Afficheur.java b/src/impl/Afficheur.java index 895888d..d91cebf 100644 --- a/src/impl/Afficheur.java +++ b/src/impl/Afficheur.java @@ -1,6 +1,6 @@ package impl; -import interfaces.Capteur; +import interfaces.CapteurAsync; import interfaces.ObserverdeCapteur; import java.util.Random; @@ -17,9 +17,9 @@ public class Afficheur implements ObserverdeCapteur { //AO1 - concrete servant @Override - public void update(Canal canalAsync) { + public void update(CapteurAsync capteurAsync) { try{ - Future futureValue= canalAsync.getValue(); + Future futureValue= capteurAsync.getValue(); Integer value=futureValue.get(); System.out.println("Afficheur " + id+", value: "+ value); }catch(Exception e){ diff --git a/src/impl/UpdateReq.java b/src/impl/UpdateReq.java index ce5dff2..3ad4023 100644 --- a/src/impl/UpdateReq.java +++ b/src/impl/UpdateReq.java @@ -1,23 +1,23 @@ package impl; -import interfaces.Capteur; +import interfaces.CapteurAsync; import interfaces.ObserverdeCapteur; import java.util.concurrent.Callable; public class UpdateReq implements Callable { - private Canal canalAsync; + private CapteurAsync canalProxy; private ObserverdeCapteur afficheur; - public UpdateReq(Canal canalAsync, ObserverdeCapteur afficheur) { - this.canalAsync = canalAsync; + public UpdateReq(CapteurAsync canalProxy, ObserverdeCapteur afficheur) { + this.canalProxy = canalProxy; this.afficheur = afficheur; } //AO1 - concrete MI @Override public Void call() { - afficheur.update(canalAsync); + afficheur.update(canalProxy); return null; } } \ No newline at end of file diff --git a/src/interfaces/ObserverdeCapteur.java b/src/interfaces/ObserverdeCapteur.java index 5b9c352..505a783 100644 --- a/src/interfaces/ObserverdeCapteur.java +++ b/src/interfaces/ObserverdeCapteur.java @@ -3,5 +3,5 @@ import impl.Canal; public interface ObserverdeCapteur{ //AO1 - servant - public void update(Canal canalAsync); + public void update(CapteurAsync capteurAsync); } diff --git a/src/main.java b/src/main.java index b1685b3..24b28e1 100644 --- a/src/main.java +++ b/src/main.java @@ -1,5 +1,3 @@ -import java.util.Timer; -import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @@ -8,11 +6,10 @@ import impl.Canal; import impl.CapteurImpl; import impl.Scheduler; import interfaces.Capteur; -import interfaces.ObserverdeCapteur; public class main { - static int NB_CANAUX = 2; + static int NB_CANAUX = 3; public static void main(String[] argv){ Scheduler scheduler = new Scheduler(NB_CANAUX);