java.util.concurrent.ConcurrentHashMap



API Populatity

225 Client projects

Project: java

Package: java.util

Project bigbluebutton/bigbluebutton in file ...nference.service.recorder.RecorderApplication.java (2013-05-28)
@@ -23,7 +23,6 @@ import org.red5.logging.Red5LoggerFactory;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;
 import java.util.concurrent.LinkedBlockingQueue;
@@ -47,6 +46,7 @@ public class RecorderApplication {
 	private Recorder recorder;
 	
 	public RecorderApplication() {
+		 messages = new LinkedBlockingQueue<RecordEvent>();
 		recordingSessions = new ConcurrentHashMap<String, String>();
 		log.debug("Instantiated ArchiveApplication");
 	}
Project elasticsearch/elasticsearch in file ...asticsearch.discovery.zen.ping.ZenPingService.java (2013-02-12)
@@ -39,7 +39,6 @@ import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 
 import java.util.Set;
-import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -129,6 +128,7 @@ public class ZenPingService extends AbstractLifecycleComponent<ZenPing> implemen
             latch.await();
             return response.get();
         } catch (InterruptedException e) {
+            logger.trace("pingAndWait interrupted");
             return null;
         }
     }
Project Atmosphere/atmosphere in file ...ain.java.org.atmosphere.cpr.AtmosphereRequest.java (2013-09-17)
@@ -54,6 +54,7 @@ import java.util.List;
 import java.util.Locale;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.Callable;
 
@@ -999,7 +1000,7 @@ public class AtmosphereRequest extends HttpServletRequestWrapper {
         private String servletPath = "";
         private String requestURI;
         private String requestURL;
-        private Map<String, Object> localAttributes = Collections.synchronizedMap(new HashMap<String, Object>());
+        private Map<String, Object> localAttributes = new ConcurrentHashMap<String, Object>();
         private InputStream inputStream;
         private String remoteAddr = "";
         private String remoteHost = "";