import EDU.oswego.cs.dl.util.concurrent.ThreadFactory; //导入依赖的package包/类
public static PooledExecutor makeThreadPool(final int keepAlive, final int maxPoolSize, final int initialThreadCount, final String threadNamePrefix) {
  final PooledExecutor result = new PooledExecutor();
  result.setThreadFactory(new ThreadFactory() {

    private int createdThreadCount = 0;


    /**
     * Creates a new thread.
     *
     * @param runnable
     */
    public Thread newThread(final Runnable runnable) {
      return makeDaemonThread(runnable, threadNamePrefix + '-' + createdThreadCount++);
    }
  });
  result.setKeepAliveTime(keepAlive);
  result.setMaximumPoolSize(maxPoolSize);
  result.setMinimumPoolSize(1);
  result.createThreads(initialThreadCount);
  return result;
}
 

import EDU.oswego.cs.dl.util.concurrent.ThreadFactory; //导入依赖的package包/类
/**
 * Singleton constructor.
 */
private AgentManager() {

  // Create upgrade executor queue
  final int poolSize = SystemConfigurationManagerFactory.getManager().getMaxParallelSystemUpgrades();
  agentUpgradeExecutor = new PooledExecutor(new LinkedQueue(), poolSize);
  agentUpgradeExecutor.setThreadFactory(new ThreadFactory() {

    public Thread newThread(final Runnable command) {

      return ThreadUtils.makeDaemonThread(command, "AgentUpgrader");
    }
  });

  agentUpgradeExecutor.setKeepAliveTime(-1L); // live forever
}
 

import EDU.oswego.cs.dl.util.concurrent.ThreadFactory; //导入依赖的package包/类
/**
 * Initializes task manager.
 */
private void initTaskManager() {
  executor = new PooledExecutor(new LinkedQueue(), 10);
  executor.setThreadFactory(new ThreadFactory() {
    public Thread newThread(final Runnable runnable) {
      return ThreadUtils.makeDaemonThread(runnable, "ParabuildTaskRunnerThread");
    }
  });
  executor.setKeepAliveTime(-1); // live forever
}