milliseconde

src/impl/CapteurImpl.java

@@ -12,13 +12,6 @@ public class CapteurImpl implements Capteur {
     public AlgoDiffusion diffusion;
     public List<ObserverDeCapteurAsync> observers=new ArrayList<ObserverDeCapteurAsync>();
 
-    /*
-    public CapteurImpl(AlgoDiffusion diffusion) {
-        value = 0;
-        observers = new ArrayList<>();
-        this.diffusion = diffusion;
-    }
-     */
     @Override
     public void attach(ObserverDeCapteurAsync o) {
         try {
@@ -29,16 +22,6 @@ public class CapteurImpl implements Capteur {
         }
     }
 
-    @Override
-    public void detach(ObserverDeCapteurAsync o) {
-        try {
-            observers.remove(o);
-        }catch(Exception e) {
-            //TODO
-            e.printStackTrace();
-        }
-    }
-
     @Override
     public void tick() {
         value++;

src/impl/Scheduler.java

@@ -15,6 +15,6 @@ public class Scheduler {
     }
 
     public <T> Future<T> enquete(Callable<T> task, long delay) {
-        return scheduler.schedule(task, delay, TimeUnit.MICROSECONDS);
+        return scheduler.schedule(task, delay, TimeUnit.MILLISECONDS);
     }
 }

src/interfaces/Capteur.java

@@ -1,7 +1,6 @@
 package interfaces;
 public interface Capteur {
     public void attach(ObserverDeCapteurAsync o);
-    public void detach(ObserverDeCapteurAsync o);
     public void tick();
 
     //AO2 - servant

src/main.java

@@ -12,7 +12,7 @@ import interfaces.ObserverdeCapteur;
 
 public class main {
 
-    static int NB_CANAUX = 10;
+    static int NB_CANAUX = 3;
 
     public static void main(String[] argv){
         Scheduler scheduler = new Scheduler(NB_CANAUX);