Changeset 691 for trunk/LogicMail/src/org/logicprobe

Timestamp:

08/21/10 15:51:17 (21 months ago)

Author:

octorian

Message:

Added static thread queue for saving to cache

File:

• trunk/LogicMail/src/org/logicprobe/LogicMail/model/MessageNode.java (modified) (3 diffs)

trunk/LogicMail/src/org/logicprobe/LogicMail/model/MessageNode.java

@@ -61 +61 @@
 import org.logicprobe.LogicMail.util.EventListenerList;
 import org.logicprobe.LogicMail.util.StringParser;
+import org.logicprobe.LogicMail.util.ThreadQueue;
 
 /**
@@ -165 +166 @@
         private boolean refreshInProgress;
 
+        /** Thread queue for calls to MailFileManager. */
+        private static final ThreadQueue threadQueue = new ThreadQueue();
+        
         /**
          * Instantiates a new message node.
@@ -627 +631 @@
         /**
          * Commits the current state of the message to the cache, if applicable.
-         * 
-         * @return True if written to cache, false otherwise
-         */
-        boolean commitMessage() {
-                boolean result = false;
+         */
+        void commitMessage() {
+            boolean writeToCache;
                 synchronized(messageContent) {
-                        if(!isCached() && isCachable()) {
-                                try {
-                                        MailFileManager.getInstance().writeMessage(this);
-                                        setCached(true);
-                                        result = true;
-                                } catch (IOException e) {
-                                        System.err.println("-->Unable to write message: " + e.getMessage());
-                                } catch (Throwable t) {
-                                        System.err.println("-->Unable to write message: " + t.getMessage());
-                                }
-                        }
-                }
-                return result;
+                    writeToCache = !isCached() && isCachable();
+                }
+                if(!writeToCache) { return; }
+                
+            synchronized (threadQueue) {
+                threadQueue.invokeLater(new Runnable() {
+                    public void run() {
+                        synchronized(messageContent) {
+                            try {
+                                MailFileManager.getInstance().writeMessage(MessageNode.this);
+                                setCached(true);
+                            } catch (Throwable t) {
+                                EventLogger.logEvent(AppInfo.GUID,
+                                        ("Unable to write message to cache\r\n"
+                                                + t.getMessage()).getBytes(),
+                                                EventLogger.ERROR);
+                            }
+                        }
+                    }
+                });
+            }
         }