本文整理了Java中java.util.concurrent.ScheduledThreadPoolExecutor.getContinueExistingPeriodicTasksAfterShutdownPolicy()
方法的一些代码示例,展示了ScheduledThreadPoolExecutor.getContinueExistingPeriodicTasksAfterShutdownPolicy()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ScheduledThreadPoolExecutor.getContinueExistingPeriodicTasksAfterShutdownPolicy()
方法的具体详情如下:
包路径:java.util.concurrent.ScheduledThreadPoolExecutor
类名称:ScheduledThreadPoolExecutor
方法名:getContinueExistingPeriodicTasksAfterShutdownPolicy
[英]Gets the policy on whether to continue executing existing periodic tasks even when this executor has been shutdown. In this case, these tasks will only terminate upon shutdownNow or after setting the policy to false when already shutdown. This value is by default false.
[中]获取即使此执行器已关闭,是否继续执行现有定期任务的策略。在这种情况下,这些任务只会在现在关机时或在已经关机时将策略设置为false后终止。默认情况下,该值为false。
代码示例来源:origin: robovm/robovm
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: org.apache.commons/commons-lang3
/**
* Tests whether a default executor service is created if no service is
* provided.
*/
@Test
public void testInitDefaultService() {
final TimedSemaphore semaphore = new TimedSemaphore(PERIOD, UNIT, LIMIT);
final ScheduledThreadPoolExecutor exec = (ScheduledThreadPoolExecutor) semaphore
.getExecutorService();
assertFalse("Wrong periodic task policy", exec
.getContinueExistingPeriodicTasksAfterShutdownPolicy());
assertFalse("Wrong delayed task policy", exec
.getExecuteExistingDelayedTasksAfterShutdownPolicy());
assertFalse("Already shutdown", exec.isShutdown());
semaphore.shutdown();
}
代码示例来源:origin: uk.org.retep.tools/annotations
/**
* {@inheritDoc}
*/
public boolean getContinueExistingPeriodicTasksAfterShutdownPolicy()
{
return executor.getContinueExistingPeriodicTasksAfterShutdownPolicy();
}
代码示例来源:origin: ibinti/bugvm
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: MobiVM/robovm
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: org.codehaus.jsr166-mirror/jsr166
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: com.gluonhq/robovm-rt
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: com.bugvm/bugvm-rt
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: com.mobidevelop.robovm/robovm-rt
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: jtulach/bck2brwsr
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: org.apidesign.bck2brwsr/emul
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: FlexoVM/flexovm
getExecuteExistingDelayedTasksAfterShutdownPolicy();
boolean keepPeriodic =
getContinueExistingPeriodicTasksAfterShutdownPolicy();
if (!keepDelayed && !keepPeriodic) {
for (Object e : q.toArray())
代码示例来源:origin: com.orientechnologies/orientdb-core
final ScheduledThreadPoolExecutor executorService = getExecutorService();
final BlockingQueue<Runnable> queue = executorService.getQueue();
final boolean abortPeriodic = !executorService.getContinueExistingPeriodicTasksAfterShutdownPolicy();
final boolean abortDelayed = !executorService.getExecuteExistingDelayedTasksAfterShutdownPolicy();
内容来源于网络,如有侵权,请联系作者删除!