import org.apache.catalina.tribes.util.TcclThreadFactory; //导入依赖的package包/类
@Override
public void startQueue() {
    if ( run ) return;
    String channelName = "";
    if (getChannel() instanceof GroupChannel
            && ((GroupChannel)getChannel()).getName() != null) {
        channelName = "[" + ((GroupChannel)getChannel()).getName() + "]";
    }
    executor = ExecutorFactory.newThreadPool(maxSpareThreads, maxThreads,
            keepAliveTime, TimeUnit.MILLISECONDS,
            new TcclThreadFactory("MessageDispatch15Interceptor.MessageDispatchThread" + channelName));
    run = true;
}
 

import org.apache.catalina.tribes.util.TcclThreadFactory; //导入依赖的package包/类
@Override
public void startQueue() {
	if (run)
		return;
	String channelName = "";
	if (getChannel() instanceof GroupChannel && ((GroupChannel) getChannel()).getName() != null) {
		channelName = "[" + ((GroupChannel) getChannel()).getName() + "]";
	}
	executor = ExecutorFactory.newThreadPool(maxSpareThreads, maxThreads, keepAliveTime, TimeUnit.MILLISECONDS,
			new TcclThreadFactory("MessageDispatch15Interceptor.MessageDispatchThread" + channelName));
	run = true;
}
 

import org.apache.catalina.tribes.util.TcclThreadFactory; //导入依赖的package包/类
@Override
public void startQueue() {
    if ( run ) return;
    executor = ExecutorFactory.newThreadPool(maxSpareThreads, maxThreads,
            keepAliveTime, TimeUnit.MILLISECONDS,
            new TcclThreadFactory("MessageDispatch15Interceptor.MessageDispatchThread"));
    run = true;
}
 

import org.apache.catalina.tribes.util.TcclThreadFactory; //导入依赖的package包/类
@Override
public void startQueue() {
    if ( run ) return;
    executor = new ThreadPoolExecutor(maxSpareThreads, maxThreads,
            keepAliveTime, TimeUnit.MILLISECONDS, runnablequeue,
            new TcclThreadFactory());
    run = true;
}