Changeset 14139 in josm for trunk/src/org/openstreetmap/josm/spi/lifecycle

Timestamp:

2018-08-12T02:52:44+02:00 (6 years ago)

Author:

Don-vip

Message:

see #15229 - move Main initialization methods to lifecycle SPI + new class MainInitialization

Location:

trunk/src/org/openstreetmap/josm/spi/lifecycle

Files:

• InitializationSequence.java (added)
• Lifecycle.java (modified) (2 diffs)

trunk/src/org/openstreetmap/josm/spi/lifecycle/Lifecycle.java

@@ -2 +2 @@
 package org.openstreetmap.josm.spi.lifecycle;
 
+import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+import org.openstreetmap.josm.tools.Logging;
+import org.openstreetmap.josm.tools.Utils;
+import org.openstreetmap.josm.tools.bugreport.BugReport;
 
 /**
@@ -31 +40 @@
         initStatusListener = Objects.requireNonNull(listener);
     }
+
+    /**
+     * Initializes the main object. A lot of global variables are initialized here.
+     * @param initSequence Initialization sequence
+     * @since 14139
+     */
+    public static void initialize(InitializationSequence initSequence) {
+        // Initializes tasks that must be run before parallel tasks
+        runInitializationTasks(initSequence.beforeInitializationTasks());
+
+        // Initializes tasks to be executed (in parallel) by a ExecutorService
+        try {
+            ExecutorService service = Executors.newFixedThreadPool(
+                    Runtime.getRuntime().availableProcessors(), Utils.newThreadFactory("main-init-%d", Thread.NORM_PRIORITY));
+            for (Future<Void> i : service.invokeAll(initSequence.parallelInitializationTasks())) {
+                i.get();
+            }
+            // asynchronous initializations to be completed eventually
+            initSequence.asynchronousRunnableTasks().forEach(service::submit);
+            initSequence.asynchronousCallableTasks().forEach(service::submit);
+            try {
+                service.shutdown();
+            } catch (SecurityException e) {
+                Logging.log(Logging.LEVEL_ERROR, "Unable to shutdown executor service", e);
+            }
+        } catch (InterruptedException | ExecutionException ex) {
+            throw new RuntimeException(ex);
+        }
+
+        // Initializes tasks that must be run after parallel tasks
+        runInitializationTasks(initSequence.afterInitializationTasks());
+    }
+
+    private static void runInitializationTasks(List<InitializationTask> tasks) {
+        for (InitializationTask task : tasks) {
+            try {
+                task.call();
+            } catch (RuntimeException e) {
+                // Can happen if the current projection needs NTV2 grid which is not available
+                // In this case we want the user be able to change his projection
+                BugReport.intercept(e).warn();
+            }
+        }
+    }
 }