Removed synchronized keywords for better performance.

Author: m0ver

src/tinystruct/examples/smalltalk.java

@@ -76,12 +76,9 @@ public talk index() {
     if(!session_ids.contains(sessionId))
     session_ids.add(sessionId);
 
-    synchronized (this.list) {
-      if(!this.list.containsKey(sessionId))
-      {
-        this.list.put(sessionId, new ConcurrentLinkedQueue<Builder>());
-      }
-      this.list.notifyAll();
+    if(!this.list.containsKey(sessionId))
+    {
+      this.list.put(sessionId, new ConcurrentLinkedQueue<Builder>());
     }
 
     this.setVariable("meeting_code", meetingCode.toString());
@@ -304,13 +301,10 @@ public void sessionCreated(HttpSessionEvent arg0) {
       System.out.println("New meeting generated by HttpSessionListener:" + meetingCode);
     }
 
-    synchronized (this.list) {
-      final String sessionId = arg0.getSession().getId();
-      if(!this.list.containsKey(sessionId))
-      {
-        this.list.put(sessionId, new ConcurrentLinkedQueue<Builder>());
-      }
-      this.list.notifyAll();
+    final String sessionId = arg0.getSession().getId();
+    if(!this.list.containsKey(sessionId))
+    {
+      this.list.put(sessionId, new ConcurrentLinkedQueue<Builder>());
     }
   }
 
@@ -327,25 +321,18 @@ public void sessionDestroyed(HttpSessionEvent arg0) {
 
       Queue<Builder> messages;
       List<String> session_ids;
-      synchronized (this.meetings) {
-        if((session_ids = this.sessions.get(meetingCode)) != null) {
-          session_ids.remove(arg0.getSession().getId());
-        }
-
-        if ((messages = this.meetings.get(meetingCode)) != null) {
-          messages.remove(meetingCode);
-        }
+      if((session_ids = this.sessions.get(meetingCode)) != null) {
+        session_ids.remove(arg0.getSession().getId());
+      }
 
-        this.meetings.notifyAll();
+      if ((messages = this.meetings.get(meetingCode)) != null) {
+        messages.remove(meetingCode);
       }
 
-      synchronized (this.list) {
-        final String sessionId = arg0.getSession().getId();
-        if(this.list.containsKey(sessionId))
-        {
-          this.list.remove(sessionId);
-        }
-        this.list.notifyAll();
+      final String sessionId = arg0.getSession().getId();
+      if(this.list.containsKey(sessionId))
+      {
+        this.list.remove(sessionId);
       }
     }
   }

src/tinystruct/examples/talk.java

@@ -25,7 +25,7 @@
 
 public class talk extends AbstractApplication {
 
-  private static final long TIMEOUT = 10;
+  private static final long TIMEOUT = 1;
   private static final int DEFAULT_POOL_SIZE = 3;
   protected static final int DEFAULT_MESSAGE_POOL_SIZE = 10;
   protected final Map<String, BlockingQueue<Builder>> meetings = new ConcurrentHashMap<String, BlockingQueue<Builder>>();
@@ -94,8 +94,7 @@ public String save(Object meetingCode, String sessionId, String message) {
   public final String save(final Object meetingCode, final Builder builder) {
     BlockingQueue<Builder> messages;
     if ((messages = this.meetings.get(meetingCode)) == null) {
-      messages = new ArrayBlockingQueue<Builder>(DEFAULT_MESSAGE_POOL_SIZE);
-      this.meetings.put(meetingCode.toString(), messages);
+      this.meetings.put(meetingCode.toString(), messages = new ArrayBlockingQueue<Builder>(DEFAULT_MESSAGE_POOL_SIZE));
     }
 
     try {
@@ -115,7 +114,6 @@ public void run() {
               e.printStackTrace();
             }
           } while(talk.this.meetings.get(meetingCode) == null || (message = talk.this.meetings.get(meetingCode).poll()) == null);
-          
           talk.this.copy(meetingCode, message);
       }
     });
@@ -135,19 +133,16 @@ private ExecutorService getService() {
    */
   public final String update(final String sessionId) throws ApplicationException, IOException {
     Builder message;
-    Queue<Builder> messages;
-    synchronized (this.list) {
-      messages = this.list.get(sessionId);
-      while((message = messages.poll()) == null) {
-        try {
-          this.list.wait(TIMEOUT);
-        } catch (InterruptedException e) {
-          throw new ApplicationException(e.getMessage(), e);
-        }
+    Queue<Builder> messages = this.list.get(sessionId);
+    while((message = messages.poll()) == null) {
+      try {
+        Thread.sleep(TIMEOUT);
+      } catch (InterruptedException e) {
+        throw new ApplicationException(e.getMessage(), e);
       }
-
-      return message.toString();
     }
+
+    return message.toString();
   }
 
   /**
@@ -165,22 +160,17 @@ protected String filter(String text) {
    * @param builder
    */
   private final void copy(Object meetingCode, Builder builder) {
-    synchronized(this.list) {
-      final Collection<Entry<String, Queue<Builder>>> set = list.entrySet();
+      final Collection<Entry<String, Queue<Builder>>> set = this.list.entrySet();
       final Iterator<Entry<String, Queue<Builder>>> iterator = set.iterator();
-      final List<String> meeting_session;
-      if((meeting_session = this.sessions.get(meetingCode)) != null) {
+      final List<String> _sessions;
+      if((_sessions = this.sessions.get(meetingCode)) != null) {
         while(iterator.hasNext()) {
-          Entry<String, Queue<Builder>> e = iterator.next();
-          if(meeting_session.contains(e.getKey())) {
-            e.getValue().add(builder);
-            this.list.notifyAll();
+          Entry<String, Queue<Builder>> list = iterator.next();
+          if(_sessions.contains(list.getKey())) {
+	            list.getValue().add(builder);
           }
         }
       }
-      else
-      this.list.notifyAll();
-    }
   }
 
   @Override