X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.indexing%2Fsrc%2Forg%2Fsimantics%2Fdb%2Findexing%2Finternal%2FIndexingJob.java;fp=bundles%2Forg.simantics.db.indexing%2Fsrc%2Forg%2Fsimantics%2Fdb%2Findexing%2Finternal%2FIndexingJob.java;h=1d00a26356182110b1c5e571c05f8b2a79077ea9;hb=091591094efd9ad65f51f3cc64616ed0c167a1ab;hp=0000000000000000000000000000000000000000;hpb=55ca14c4198659b908aeffc8d16e240b35a75e66;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.db.indexing/src/org/simantics/db/indexing/internal/IndexingJob.java b/bundles/org.simantics.db.indexing/src/org/simantics/db/indexing/internal/IndexingJob.java
new file mode 100644
index 000000000..1d00a2635
--- /dev/null
+++ b/bundles/org.simantics.db.indexing/src/org/simantics/db/indexing/internal/IndexingJob.java
@@ -0,0 +1,92 @@
+/*******************************************************************************
+ * Copyright (c) 2016 Association for Decentralized Information Management in
+ * Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Semantum Oy - initial API and implementation
+ *******************************************************************************/
+package org.simantics.db.indexing.internal;
+
+import java.util.concurrent.Semaphore;
+
+import org.eclipse.core.runtime.IProgressMonitor;
+import org.eclipse.core.runtime.IStatus;
+import org.eclipse.core.runtime.jobs.Job;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.function.DbConsumer;
+
+/**
+ * @author Tuukka Lehtonen
+ * @since 1.22.2, 1.25.0
+ */
+public abstract class IndexingJob extends Job {
+
+    /**
+     * NOTE: this is intentionally the same as
+     * <code>org.simantics.DatabaseJob.DATABASE_JOB_FAMILY</code> in order for
+     * this job to cause the same UI-behavior as DatabaseJob.
+     */
+    private static final String DATABASE_JOB_FAMILY = "org.simantics.db.inDatabaseJob";
+
+    public IndexingJob(String name) {
+        super(name);
+    }
+
+    @Override
+    public boolean belongsTo(Object family) {
+        return DATABASE_JOB_FAMILY.equals(family);
+    }
+
+    /**
+     * @param monitor
+     * @param jobName
+     * @param consumer
+     * @throws DatabaseException
+     */
+    public static void jobifyIfPossible(
+            IProgressMonitor monitor,
+            String jobName,
+            DbConsumer<IProgressMonitor> consumer)
+                    throws DatabaseException
+    {
+        // Prevent deadlocks by checking preconditions for using a job.
+        // JobManager is suspended e.g. during workbench startup.
+        if (Job.getJobManager().isSuspended() || Job.getJobManager().currentJob() != null) {
+            consumer.accept(monitor);
+            return;
+        }
+
+        Semaphore barrier = new Semaphore(0);
+        Throwable[] err = { null };
+        IndexingJob job = new IndexingJob(jobName) {
+            @Override
+            protected IStatus run(IProgressMonitor monitor) {
+                try {
+                    consumer.accept(monitor);
+                } catch (Throwable t) {
+                    err[0] = t;
+                } finally {
+                    monitor.done();
+                    barrier.release();
+                }
+                return org.eclipse.core.runtime.Status.OK_STATUS;
+            }
+        };
+        job.schedule();
+        try {
+            barrier.acquire();
+            if (err[0] != null) {
+                if (err[0] instanceof DatabaseException)
+                    throw (DatabaseException) err[0];
+                throw new DatabaseException(err[0]);
+            }
+        } catch (InterruptedException e) {
+            throw new DatabaseException(e);
+        }
+    }
+
+}