feat: mutiple managers ?

src/main/java/linda/search/basic/Main.java

@@ -4,24 +4,29 @@ import linda.*;
 
 public class Main {
 
-    private static final int NB_MANAGER = 1;
     private static final int NB_SEARCHER = 10;
 
-    public static void main(String args[]) {
+    public static void main(String args[]) throws InterruptedException {
         // if (args.length != 2) {
         // System.err.println("linda.search.basic.Main search file.");
         // return;
         // }
         Linda linda = new linda.shm.CentralizedLinda();
 
-        for (int i = 0; i < NB_MANAGER; i++) {
-            Manager manager = new Manager(linda, "/usr/share/dict/french", "agneau");
-            (new Thread(manager)).start();
-        }
+        Manager manager1 = new Manager(linda, "/usr/share/dict/french", "abasourdir");
+        Thread thread1 = new Thread(manager1);
+        thread1.start();
+
+        Manager manager2 = new Manager(linda, "/usr/share/dict/french", "agneau");
+        Thread thread2 = new Thread(manager2);
+        thread2.start();
 
         for (int i = 0; i < NB_SEARCHER; i++) {
             Searcher searcher = new Searcher(linda);
             (new Thread(searcher)).start();
         }
+
+        thread1.join();
+        thread2.join();
     }
 }

src/main/java/linda/search/basic/Manager.java

@@ -64,7 +64,6 @@ public class Manager implements Runnable {
                 bestvalue = v;
                 bestresult = s;
                 System.out.println("New best (" + bestvalue + "): \"" + bestresult + "\"");
-                System.out.flush();
             }
 
             // Tant qu'il reste des mots à chercher, ou des résultats à traiter

src/main/java/linda/search/basic/Searcher.java

@@ -17,7 +17,6 @@ public class Searcher implements Runnable {
         UUID reqUUID = (UUID) treq.get(1);
         String req = (String) treq.get(2);
         System.out.println("Looking for: " + req);
-        System.out.flush();
 
         Tuple tv;
         while ((tv = linda.tryTake(new Tuple(Code.Value, String.class, reqUUID))) != null) {
@@ -29,7 +28,6 @@ public class Searcher implements Runnable {
         }
 
         System.out.println("Ending search: " + req);
-        System.out.flush();
 
         Tuple end = new Tuple(Code.Searcher, "done", reqUUID);
         if (linda.tryRead(end) == null)
@@ -38,7 +36,6 @@ public class Searcher implements Runnable {
 
     public void run() {
         System.out.println("Ready to search");
-        System.out.flush();
 
         linda.read(new Tuple(Code.Request, UUID.class, String.class));
         Collection<Tuple> treqs = linda.readAll(new Tuple(Code.Request, UUID.class, String.class));

src/main/java/linda/shm/CentralizedLinda.java

@@ -244,9 +244,11 @@ public class CentralizedLinda implements Linda {
                         return;
                     case FUTURE:
                         Collection<Tuple> knownTuples = new ArrayList<Tuple>();
+                        synchronized (tuples) {
                             for (Tuple t : tuples) {
                                 knownTuples.add((Tuple) t.clone());
                             }
+                        }
                         callback.call(future_search(template, knownTuples, mode));
                         return;
                 }