bundles/org.simantics.diagram/src/org/simantics/diagram/synchronization/ThreadingModificationProxy.java

   1 /*******************************************************************************\r
   2  * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
   3  * in Industry THTH ry.\r
   4  * All rights reserved. This program and the accompanying materials\r
   5  * are made available under the terms of the Eclipse Public License v1.0\r
   6  * which accompanies this distribution, and is available at\r
   7  * http://www.eclipse.org/legal/epl-v10.html\r
   8  *\r
   9  * Contributors:\r
  10  *     VTT Technical Research Centre of Finland - initial API and implementation\r
  11  *******************************************************************************/\r
  12 package org.simantics.diagram.synchronization;\r
  13 \r
  14 import org.simantics.db.WriteGraph;\r
  15 import org.simantics.utils.threads.IThreadWorkQueue;\r
  16 import org.simantics.utils.threads.ThreadUtils;\r
  17 \r
  18 /**\r
  19  * @author Tuukka Lehtonen\r
  20  */\r
  21 public class ThreadingModificationProxy extends ModificationAdapter {\r
  22     private final IModification    m;\r
  23     private final IThreadWorkQueue completionThread;\r
  24     private final boolean          syncCompletion;\r
  25 \r
  26     public ThreadingModificationProxy(IModification m, IThreadWorkQueue completionThread, boolean syncCompletion) {\r
  27         super(m.getPriority());\r
  28         this.m = m;\r
  29         this.completionThread = completionThread;\r
  30         this.syncCompletion = syncCompletion;\r
  31     }\r
  32     @Override\r
  33     public void completed() {\r
  34         if (completionThread != null) {\r
  35             Runnable r = new Runnable() {\r
  36                 @Override\r
  37                 public void run() {\r
  38                     m.completed();\r
  39                 }\r
  40             };\r
  41             if (syncCompletion)\r
  42                 ThreadUtils.syncExec(completionThread, r);\r
  43             else\r
  44                 ThreadUtils.asyncExec(completionThread, r);\r
  45         } else {\r
  46             m.completed();\r
  47         }\r
  48     }\r
  49     @Override\r
  50     public boolean isComplete() {\r
  51         return m.isComplete();\r
  52     }\r
  53     @Override\r
  54     public void markComplete() {\r
  55         m.markComplete();\r
  56     }\r
  57     @Override\r
  58     public void perform(WriteGraph g) throws Exception {\r
  59         m.perform(g);\r
  60     }\r
  61     @Override\r
  62     public Throwable getException() {\r
  63         return m.getException();\r
  64     }\r
  65     @Override\r
  66     public void setException(Throwable t) {\r
  67         m.setException(t);\r
  68     }\r
  69     @Override\r
  70     public String toString() {\r
  71         return getClass().getSimpleName() + "[" + m + "]";\r
  72     }\r
  73 }