MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

don't leak MessageBus and all its listeners through ThreadLocal

Browse Source
This commit is contained in:
peter
2012-05-25 19:25:43 +02:00
parent b42a74eaa9
commit 1467a165b0
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/util/src/com/intellij/util/messages/impl/MessageBusConnectionImpl.java
+8 -6
View File
@@ -34,12 +34,7 @@ public class MessageBusConnectionImpl implements MessageBusConnection {
private static final Logger LOG = Logger.getInstance("#com.intellij.util.messages.impl.MessageBusConnectionImpl");
private final MessageBusImpl myBus;
private final ThreadLocal<Queue<Message>> myPendingMessages = new ThreadLocal<Queue<Message>>() {
@Override
protected Queue<Message> initialValue() {
return new ConcurrentLinkedQueue<Message>();
}
};
private final ThreadLocal<Queue<Message>> myPendingMessages = new QueueThreadLocal();
private MessageHandler myDefaultHandler;
private final Map<Topic, Object> mySubscriptions = new HashMap<Topic, Object>();
@@ -129,4 +124,11 @@ public class MessageBusConnectionImpl implements MessageBusConnection {
public String toString() {
return mySubscriptions.keySet().toString();
}
private static class QueueThreadLocal extends ThreadLocal<Queue<Message>> {
@Override
protected Queue<Message> initialValue() {
return new ConcurrentLinkedQueue<Message>();
}
}
}