vanitasvitae
/
Smack
mirror of https://github.com/vanitasvitae/Smack.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Align thread names

This commit is contained in:
Florian Schmaus 2015-01-10 00:51:57 +01:00
parent 8e74f7faed
commit 8c8ac546a9
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
smack-core/src/main/java/org/jivesoftware/smack/AbstractXMPPConnection.java
View File

@ -230,7 +230,7 @@ public abstract class AbstractXMPPConnection implements XMPPConnection {
* PacketListeners are invoked in the same order the stanzas arrived. * PacketListeners are invoked in the same order the stanzas arrived.
*/ */
private final ThreadPoolExecutor executorService = new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, private final ThreadPoolExecutor executorService = new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(100), new SmackExecutorThreadFactory(connectionCounterValue, "IncomingNotifier")); new ArrayBlockingQueue<Runnable>(100), new SmackExecutorThreadFactory(connectionCounterValue, "Incoming Processor"));
/** /**
* Creates an executor service just as {@link Executors#newCachedThreadPool()} would do, but with a keep alive time * Creates an executor service just as {@link Executors#newCachedThreadPool()} would do, but with a keep alive time
@ -246,7 +246,7 @@ public abstract class AbstractXMPPConnection implements XMPPConnection {
new SynchronousQueue<Runnable>(), // workQueue new SynchronousQueue<Runnable>(), // workQueue
new SmackExecutorThreadFactory( // threadFactory new SmackExecutorThreadFactory( // threadFactory
connectionCounterValue, connectionCounterValue,
"CachedExecutor" "Cached Executor"
) )
// @formatter:on // @formatter:on
); );
@ -257,7 +257,7 @@ public abstract class AbstractXMPPConnection implements XMPPConnection {
* is the same as the order of the incoming stanzas. Therefore we use a <i>single</i> threaded executor service. * is the same as the order of the incoming stanzas. Therefore we use a <i>single</i> threaded executor service.
*/ */
private final ExecutorService singleThreadedExecutorService = Executors.newSingleThreadExecutor(new SmackExecutorThreadFactory( private final ExecutorService singleThreadedExecutorService = Executors.newSingleThreadExecutor(new SmackExecutorThreadFactory(
getConnectionCounter(), "Sync PacketListener Callback")); getConnectionCounter(), "Single Threaded Executor"));
private Roster roster; private Roster roster;
@ -1375,7 +1375,7 @@ public abstract class AbstractXMPPConnection implements XMPPConnection {
} }
private final ScheduledExecutorService removeCallbacksService = new ScheduledThreadPoolExecutor(1, private final ScheduledExecutorService removeCallbacksService = new ScheduledThreadPoolExecutor(1,
new SmackExecutorThreadFactory(connectionCounterValue, "RemoveCallbacks")); new SmackExecutorThreadFactory(connectionCounterValue, "Remove Callbacks"));
@Override @Override
public void sendStanzaWithResponseCallback(Packet stanza, PacketFilter replyFilter, public void sendStanzaWithResponseCallback(Packet stanza, PacketFilter replyFilter,