X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fio%2FBackupFiles.java;h=88524d17d37d7a936c6ddee1c5a860cb20e17887;hb=b364e1e6d199002069dab615d1007799b5bb71e1;hp=529e1b2acfe66f2f65fc1bcae8d491b72972f777;hpb=0980e87380e2922790d01bde3f616115f1916a43;p=jalview.git

diff --git a/src/jalview/io/BackupFiles.java b/src/jalview/io/BackupFiles.java
index 529e1b2..88524d1 100644
--- a/src/jalview/io/BackupFiles.java
+++ b/src/jalview/io/BackupFiles.java
@@ -32,6 +32,11 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.TreeMap;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
 
 import jalview.bin.Cache;
 import jalview.bin.Console;
@@ -106,8 +111,14 @@ public class BackupFiles
 
   private static final String oldTempFileSuffix = "_oldfile_tobedeleted";
 
+  // thread pool used for completablefutures
+  private static final ExecutorService executorService = Executors
+          .newFixedThreadPool(3);
+
   private static List<BackupFiles> savesInProgress = new ArrayList<>();
 
+  private CompletableFuture<Boolean> myFuture = null;
+
   private boolean addSaveInProgress()
   {
     if (savesInProgress.contains(this))
@@ -116,25 +127,41 @@ public class BackupFiles
     }
     else
     {
+      this.setMyFuture();
       savesInProgress.add(this);
       return true;
     }
   }
 
-  private boolean removeSaveInProgress()
+  private boolean removeSaveInProgress(boolean ret)
   {
     if (savesInProgress.contains(this))
     {
+      this.getMyFuture().complete(ret);
       // remove all occurrences
       while (savesInProgress.remove(this))
       {
       }
       return true;
     }
-    else
+    return false;
+  }
+
+  private static CompletableFuture<Boolean> getNewFuture()
+  {
+    return new CompletableFuture<Boolean>()
     {
-      return false;
-    }
+    };
+  }
+
+  private CompletableFuture<Boolean> getMyFuture()
+  {
+    return this.myFuture;
+  }
+
+  private void setMyFuture()
+  {
+    this.myFuture = getNewFuture();
   }
 
   public static boolean hasSavesInProgress()
@@ -152,6 +179,41 @@ public class BackupFiles
     return files;
   }
 
+  public static List<CompletableFuture<Boolean>> savesInProgressCompletableFutures()
+  {
+    List<CompletableFuture<Boolean>> cfs = new ArrayList<>();
+    for (BackupFiles bfile : savesInProgress)
+    {
+      cfs.add(bfile.getMyFuture());
+    }
+    return cfs;
+  }
+
+  public static Future<Boolean> allSaved()
+  {
+    CompletableFuture<Boolean> f = new CompletableFuture<>();
+
+    executorService.submit(() -> {
+      for (BackupFiles buf : savesInProgress)
+      {
+        boolean allSaved = true;
+        try
+        {
+          allSaved &= buf.getMyFuture().get();
+        } catch (InterruptedException e)
+        {
+          Console.debug("InterruptedException waiting for files to save",
+                  e);
+        } catch (ExecutionException e)
+        {
+          Console.debug("ExecutionException waiting for files to save", e);
+        }
+        f.complete(allSaved);
+      }
+    });
+    return f;
+  }
+
   public BackupFiles(String filename)
   {
     this(new File(filename));
@@ -871,7 +933,7 @@ public class BackupFiles
     }
 
     // remove this file from the save in progress stack
-    removeSaveInProgress();
+    removeSaveInProgress(rename);
 
     return rename;
   }