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

ScheduledThreadPoolExecutor.getTaskCount介绍

暂无

代码示例

代码示例来源：origin: gravitee-io/gravitee-gateway

public long getTaskCount() {
  return SubscriptionsServiceHandler.this.executorService.getTaskCount();
}

代码示例来源：origin: gravitee-io/gravitee-gateway

public long getTaskCount() {
  return ApiKeysServiceHandler.this.executorService.getTaskCount();
}

代码示例来源：origin: io.gravitee.gateway.services/gravitee-gateway-services-apikeyscache

public long getTaskCount() {
  return ApiKeysServiceHandler.this.executorService.getTaskCount();
}

代码示例来源：origin: io.gravitee.gateway.services/gravitee-gateway-services-subscriptions-cache

public long getTaskCount() {
  return SubscriptionsServiceHandler.this.executorService.getTaskCount();
}

代码示例来源：origin: wildfly/wildfly-core

public long getTaskCount() {
  return executor.getTaskCount();
}

代码示例来源：origin: AmadeusITGroup/HttpSessionReplacer

@Override
 public Long getValue() {
  return scheduledExecutor.getTaskCount();
 }
});

代码示例来源：origin: kieker-monitoring/kieker

@Override
public final String toString() {
  final StringBuilder sb = new StringBuilder(128);
  sb.append("Sampling Controller: ");
  if (this.periodicSensorsPoolExecutor != null) {
    sb.append("Periodic Sensor available: Poolsize: '");
    sb.append(this.periodicSensorsPoolExecutor.getPoolSize());
    sb.append("'; Scheduled Tasks: '");
    sb.append(this.periodicSensorsPoolExecutor.getTaskCount());
    sb.append('\''); // no \n in last controller
  } else {
    sb.append("No periodic Sensor available"); // no \n in last controller
  }
  return sb.toString();
}

代码示例来源：origin: net.kieker-monitoring/kieker

@Override
public final String toString() {
  final StringBuilder sb = new StringBuilder(128);
  sb.append("Sampling Controller: ");
  if (this.periodicSensorsPoolExecutor != null) {
    sb.append("Periodic Sensor available: Poolsize: '");
    sb.append(this.periodicSensorsPoolExecutor.getPoolSize());
    sb.append("'; Scheduled Tasks: '");
    sb.append(this.periodicSensorsPoolExecutor.getTaskCount());
    sb.append('\''); // no \n in last controller
  } else {
    sb.append("No periodic Sensor available"); // no \n in last controller
  }
  return sb.toString();
}

代码示例来源：origin: net.disy.htmlunit/htmlunit

/**
 * Returns the approximate number of jobs currently executing and waiting to be executed. This
 * method can only guarantee approximate results, because these are the only guarantees provided
 * by the {@link ScheduledThreadPoolExecutor} API which this method is built on.
 * @return the approximate number of jobs currently executing and waiting to be executed
 */
private synchronized int getJobCountInner() {
  executor_.purge();
  return (int) (executor_.getTaskCount() - executor_.getCompletedTaskCount());
}

代码示例来源：origin: org.jvnet.hudson/htmlunit

/**
 * Returns the approximate number of jobs currently executing and waiting to be executed. This
 * method can only guarantee approximate results, because these are the only guarantees provided
 * by the {@link ScheduledThreadPoolExecutor} API which this method is built on.
 * @return the approximate number of jobs currently executing and waiting to be executed
 */
private synchronized int getJobCountInner() {
  executor_.purge();
  return (int) (executor_.getTaskCount() - executor_.getCompletedTaskCount());
}

代码示例来源：origin: org.jenkins-ci/htmlunit

/**
 * Returns the approximate number of jobs currently executing and waiting to be executed. This
 * method can only guarantee approximate results, because these are the only guarantees provided
 * by the {@link ScheduledThreadPoolExecutor} API which this method is built on.
 * @return the approximate number of jobs currently executing and waiting to be executed
 */
private synchronized int getJobCountInner() {
  executor_.purge();
  return (int) (executor_.getTaskCount() - executor_.getCompletedTaskCount());
}

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

/**
 * Updates the write status.
 */
private void checkWritingStatus() {
  if (null != writingExecutorService) {
    long completedTasks = writingExecutorService.getCompletedTaskCount();
    long queuedTasks = writingExecutorService.getTaskCount() - completedTasks;
    long arrivedTasksForPeriod = (queuedTasks + completedTasks) - totalTasks;
    long finishedTasksForPeriod = completedTasks - finishedTasks;
    writingStatus = WritingStatus.getWritingStatus(arrivedTasksForPeriod, finishedTasksForPeriod);
    finishedTasks = completedTasks;
    totalTasks = completedTasks + queuedTasks;
  } else {
    writingStatus = WritingStatus.GOOD;
  }
}

代码示例来源：origin: com.google.code.maven-play-plugin.org.playframework/play

pool.addProperty("size", Invoker.executor.getPoolSize());
pool.addProperty("active", Invoker.executor.getActiveCount());
pool.addProperty("scheduled", Invoker.executor.getTaskCount());
pool.addProperty("queue", Invoker.executor.getQueue().size());
status.add("pool", pool);

代码示例来源：origin: com.google.code.maven-play-plugin.org.playframework/play

out.println("Pool size: " + executor.getPoolSize());
out.println("Active count: " + executor.getActiveCount());
out.println("Scheduled task count: " + executor.getTaskCount());
out.println("Queue size: " + executor.getQueue().size());
SimpleDateFormat df = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss");

代码示例来源：origin: com.google.code.maven-play-plugin.org.playframework/play

out.println("Pool size: " + Invoker.executor.getPoolSize());
out.println("Active count: " + Invoker.executor.getActiveCount());
out.println("Scheduled task count: " + Invoker.executor.getTaskCount());
out.println("Queue size: " + Invoker.executor.getQueue().size());
out.println();

代码示例来源：origin: OpenNMS/opennms

private synchronized void scheduleReads(final ScheduledThreadPoolExecutor executor) {
  LOG.debug("scheduleReads: acquired lock, creating schedule...");
  executor.setContinueExistingPeriodicTasksAfterShutdownPolicy(false);
  executor.setExecuteExistingDelayedTasksAfterShutdownPolicy(false);
  m_future = executor.scheduleWithFixedDelay(this.getAckProcessor(), getSchedule().getInitialDelay(), 
      getSchedule().getInterval(), getSchedule().getUnit());
  LOG.debug("scheduleReads: exited lock, schedule updated.");
  LOG.debug("scheduleReads: schedule is: attempts remaining: {}; initial delay: {}; interval: {}; unit: {}",
       getSchedule().getAttemptsRemaining(),
       getSchedule().getInitialDelay(),
       getSchedule().getInterval(),
       getSchedule().getUnit());
  LOG.debug("scheduleReads: executor details: active count: {}; completed task count: {}; task count: {}; queue size: {}", executor.getActiveCount(), executor.getCompletedTaskCount(), executor.getTaskCount(), executor.getQueue().size());
}

代码示例来源：origin: apache/activemq-artemis

@Test
  public void testJobsGetScheduledToSuppliedThreadPool() throws Exception {
   server.stop();

   ScheduledThreadPoolExecutor scheduledExecutorService = (ScheduledThreadPoolExecutor) server.getScheduledPool();

   Field field = server.getExecutorFactory().getClass().getDeclaredField("parent");
   field.setAccessible(true);
   ThreadPoolExecutor threadPool = (ThreadPoolExecutor) field.get(server.getExecutorFactory());

   // Check jobs are getting scheduled and executed.
   assertTrue(threadPool.getCompletedTaskCount() > 0);
   assertTrue(scheduledExecutorService.getTaskCount() > 0);
  }
}

代码示例来源：origin: fujitsu-pio/io

/**
 * ExecutorServiceの起動_終了テスト.
 */
@Test
@Ignore
public void ExecutorServiceの起動_終了テスト() {
  RepairServiceLauncher launcher = new RepairServiceLauncher();
  assertThat(launcher.executor.getPoolSize(), is(1));
  assertThat(launcher.executor.getTaskCount(), is(1L));
  launcher.shutdown();
  assertThat(launcher.executor.isTerminated(), is(true));
  assertThat(launcher.executor.isShutdown(), is(true));
}