本文整理了Java中java.util.concurrent.ScheduledThreadPoolExecutor.prestartAllCoreThreads()方法的一些代码示例，展示了ScheduledThreadPoolExecutor.prestartAllCoreThreads()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ScheduledThreadPoolExecutor.prestartAllCoreThreads()方法的具体详情如下：
包路径：java.util.concurrent.ScheduledThreadPoolExecutor
类名称：ScheduledThreadPoolExecutor
方法名：prestartAllCoreThreads

ScheduledThreadPoolExecutor.prestartAllCoreThreads介绍

暂无

代码示例

代码示例来源：origin: oracle/helidon

@Override
public synchronized ScheduledThreadPoolExecutor get() {
  if (null == instance) {
    instance = new ScheduledThreadPoolExecutor(corePoolSize,
        new ThreadFactory() {
          private AtomicInteger value = new AtomicInteger();
          @Override
          public Thread newThread(Runnable r) {
            Thread t = new Thread(null,
                r,
                threadNamePrefix + value.incrementAndGet());
            t.setDaemon(isDaemon);
            return t;
          }
        });
    if (prestart) {
      instance.prestartAllCoreThreads();
    }
  }
  return instance;
}

代码示例来源：origin: i2p/i2p.i2p

/**
 *  To be instantiated by the context.
 *  Others should use context.simpleTimer() instead
 *  @deprecated in 0.9.20, replaced by SimpleTimer2
 */
@Deprecated
private SimpleScheduler(I2PAppContext context, String name) {
  _log = context.logManager().getLog(SimpleScheduler.class);
  _name = name;
  long maxMemory = SystemVersion.getMaxMemory();
  _threads = (int) Math.max(MIN_THREADS, Math.min(MAX_THREADS, 1 + (maxMemory / (32*1024*1024))));
  _executor = new ScheduledThreadPoolExecutor(_threads, new CustomThreadFactory());
  _executor.prestartAllCoreThreads();
  // don't bother saving ref to remove hook if somebody else calls stop
  context.addShutdownTask(new Shutdown());
}

代码示例来源：origin: i2p/i2p.i2p

/**
 *  To be instantiated by the context.
 *  Others should use context.simpleTimer2() instead
 *  @since 0.9
 */
protected SimpleTimer2(I2PAppContext context, String name, boolean prestartAllThreads) {
  _name = name;
  long maxMemory = SystemVersion.getMaxMemory();
  _threads = (int) Math.max(MIN_THREADS, Math.min(MAX_THREADS, 1 + (maxMemory / (32*1024*1024))));
  _executor = new CustomScheduledThreadPoolExecutor(_threads, new CustomThreadFactory());
  if (prestartAllThreads)
    _executor.prestartAllCoreThreads();
  // don't bother saving ref to remove hook if somebody else calls stop
  context.addShutdownTask(new Shutdown());
}

代码示例来源：origin: org.mobicents.servlet.sip/sip-servlets-impl

public void start() {
  scheduledExecutor.prestartAllCoreThreads();		
}

代码示例来源：origin: opendaylight/controller

public ScheduledThreadPoolWrapper(int threadCount, ThreadFactory factory) {
  this.threadCount = threadCount;
  this.executor = new ScheduledThreadPoolExecutor(threadCount, factory);
  executor.prestartAllCoreThreads();
}

代码示例来源：origin: org.opendaylight.controller/threadpool-config-impl

public ScheduledThreadPoolWrapper(int threadCount, ThreadFactory factory) {
  this.threadCount = threadCount;
  this.executor = new ScheduledThreadPoolExecutor(threadCount, factory);
  executor.prestartAllCoreThreads();
}

代码示例来源：origin: org.apache.qpid/qpid-broker-plugins-jdbc-store

protected void initMessageStore(final ConfiguredObject<?> parent)
{
  _parent = parent;
  _executor = new ScheduledThreadPoolExecutor(4, new ThreadFactory()
  {
    private final AtomicInteger _count = new AtomicInteger();
    @Override
    public Thread newThread(final Runnable r)
    {
      final Thread thread = Executors.defaultThreadFactory().newThread(r);
      thread.setName(parent.getName() + "-store-"+_count.incrementAndGet());
      return thread;
    }
  });
  _executor.prestartAllCoreThreads();
}

代码示例来源：origin: org.mobicents.media/scheduler

@Override
public void start() {
  if (!this.started) {
    this.started = true;
    this.executor = Executors.newScheduledThreadPool(POOL_SIZE, threadFactory);
    ((ScheduledThreadPoolExecutor) this.executor).setRemoveOnCancelPolicy(true);
    ((ScheduledThreadPoolExecutor) this.executor).prestartAllCoreThreads();
    LOGGER.info("Started scheduler!");
  }
}

代码示例来源：origin: org.restcomm.media/scheduler

@Override
public void start() {
  if (!this.started) {
    this.started = true;
    this.executor = Executors.newScheduledThreadPool(POOL_SIZE, threadFactory);
    ((ScheduledThreadPoolExecutor) this.executor).setRemoveOnCancelPolicy(true);
    ((ScheduledThreadPoolExecutor) this.executor).prestartAllCoreThreads();
    LOGGER.info("Started scheduler!");
  }
}

代码示例来源：origin: org.restcomm.media.server.standalone/media-server-standalone-bootstrap

@Bean("MgcpScheduler")
public ListeningScheduledExecutorService listeningScheduledExecutorService() {
  ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("mgcp-%d").build();
  // TODO set uncaught exception handler
  ScheduledThreadPoolExecutor executor = (ScheduledThreadPoolExecutor) Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors(), threadFactory);
  executor.prestartAllCoreThreads();
  executor.setRemoveOnCancelPolicy(true);
  return MoreExecutors.listeningDecorator(executor);
}

代码示例来源：origin: org.restcomm.media.core/media-core-scheduler

@Override
public void start() {
  if (!this.started) {
    this.started = true;
    this.executor = Executors.newScheduledThreadPool(POOL_SIZE, threadFactory);
    ((ScheduledThreadPoolExecutor) this.executor).setRemoveOnCancelPolicy(true);
    ((ScheduledThreadPoolExecutor) this.executor).prestartAllCoreThreads();
    LOGGER.info("Started scheduler!");
  }
}

代码示例来源：origin: org.jitsi/jain-sip-ri-ossonly

public void start(SipStackImpl sipStack, Properties configurationProperties) {
  sipStackImpl= sipStack;
  // TODO have a param in the stack properties to set the number of thread for the timer executor
  threadPoolExecutor.prestartAllCoreThreads();
  schedulePurgeTaskIfNeeded();
  if(logger.isLoggingEnabled(StackLogger.TRACE_INFO)) {
    logger.logInfo("the sip stack timer " + this.getClass().getName() + " has been started");
  }
}
/*

代码示例来源：origin: threadly/threadly

@Override
public SubmitterScheduler makeSubmitterScheduler(int poolSize, boolean prestartIfAvailable) {
 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(poolSize);
 if (prestartIfAvailable) {
  executor.prestartAllCoreThreads();
 }
 executors.add(executor);
 return new ScheduledExecutorServiceWrapper(executor);
}

代码示例来源：origin: apache/ofbiz-framework

public static ScheduledExecutorService getScheduledExecutor(ThreadGroup group, String namePrefix, int threadCount, long keepAliveSeconds, boolean preStart) {
  ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(threadCount, new ExecutionPoolThreadFactory(group, namePrefix));
  if (keepAliveSeconds > 0) {
    executor.setKeepAliveTime(keepAliveSeconds, TimeUnit.SECONDS);
    executor.allowCoreThreadTimeOut(true);
  }
  if (preStart) {
    executor.prestartAllCoreThreads();
  }
  return executor;
}

代码示例来源：origin: org.mobicents.javax.sip/mobicents-jain-sip-ext

public void init(SipStack stack) {
  sipStack = (SipStackExtension) stack;
  logger.logInfo("Initializing congestion control valve");
  String blockedValues = sipStack.getConfigurationProperties().getProperty("org.mobicents.ext.javax.sip.congestion.SIP_SCANNERS", "sipvicious,sipcli,friendly-scanner");
  blockedList = new ArrayList<String>(Arrays.asList(blockedValues.split(",")));
  String congestionControlMonitoringIntervalString = sipStack.getConfigurationProperties().getProperty("org.mobicents.ext.javax.sip.congestion.CONGESTION_CONTROL_MONITOR_INTERVAL", "30000");
  congestionControlMonitoringInterval = new Integer(congestionControlMonitoringIntervalString);
  if(congestionControlTimerFuture == null && congestionControlMonitoringInterval > 0) { 					
    String dropResponseStatusString = sipStack.getConfigurationProperties().getProperty("org.mobicents.ext.javax.sip.congestion.DROP_RESPONSE_STATUS", "503");
    dropResponseStatus = new Integer(dropResponseStatusString);
          
    congestionControlThreadPool = new ScheduledThreadPoolExecutor(2,
        new ThreadPoolExecutor.CallerRunsPolicy());
    congestionControlThreadPool.prestartAllCoreThreads();
    CongestionControlTimerTask congestionControlTimerTask = new CongestionControlTimerTask(this, sipStack);
    
      congestionControlTimerFuture = congestionControlThreadPool.scheduleWithFixedDelay(congestionControlTimerTask, 0, congestionControlMonitoringInterval, TimeUnit.MILLISECONDS);
    if(logger.isLoggingEnabled(CommonLogger.TRACE_INFO)) {
       logger.logInfo("Congestion control background task started and checking every " + congestionControlMonitoringInterval + " milliseconds.");
     }
  } else {
    if(logger.isLoggingEnabled(CommonLogger.TRACE_INFO)) {
       logger.logInfo("No Congestion control background task started since the checking interval is equals to " + congestionControlMonitoringInterval + " milliseconds.");
     }
  }
}

代码示例来源：origin: org.mobicents.servlet.sip/sip-servlets-impl

asynchronousScheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2, new NamingThreadFactory("sip_servlets_congestion_control"),
    new ThreadPoolExecutor.CallerRunsPolicy());
asynchronousScheduledThreadPoolExecutor.prestartAllCoreThreads();	
logger.info("AsynchronousThreadPoolExecutor size is " + sipService.getDispatcherThreadPoolSize());		
asynchronousExecutor = new ThreadPoolExecutor(sipService.getDispatcherThreadPoolSize(), 64, 90, TimeUnit.SECONDS,