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

Jobs.wrap介绍

暂无

代码示例

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

public static ScheduledFuture<?> scheduleWithFixedDelay(Runnable job, long initialDelay, long delay, TimeUnit unit) {
  return requireActiveScheduler().scheduleWithFixedDelay(wrap(job), initialDelay, delay, unit);
}

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

public static ScheduledFuture<?> scheduleAtFixedRate(Runnable job, long initialDelay, long period, TimeUnit unit) {
  return requireActiveScheduler().scheduleAtFixedRate(wrap(job), initialDelay, period, unit);
}

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

public static ScheduledFuture<?> schedule(Runnable job, long delay, TimeUnit unit) {
  return requireActiveScheduler().schedule(wrap(job), delay, unit);
}

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

public static void execute(Runnable job) {
  Opt<ThreadPoolExecutor> executor = jobs.executor();
  if (executor.exists()) {
    ContextPreservingJobWrapper jobWrapper = wrap(job);
    try {
      executor.get().execute(jobWrapper);
    } catch (RejectedExecutionException e) {
      Log.warn("Job execution was rejected!", "job", job);
    }
  }
}

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

public static void executeAndWait(Runnable job) {
  Opt<ThreadPoolExecutor> executor = jobs.executor();
  if (executor.exists()) {
    ContextPreservingJobWrapper jobWrapper = wrap(job);
    try {
      executor.get().execute(jobWrapper);
    } catch (RejectedExecutionException e) {
      Log.warn("Job execution was rejected!", "job", job);
    }
    while (!jobWrapper.isDone()) {
      U.sleep(10);
    }
  }
}

代码示例来源：origin: org.rapidoid/rapidoid-ctx

public static ScheduledFuture<?> scheduleAtFixedRate(Runnable job, long initialDelay, long period, TimeUnit unit) {
  return scheduler().scheduleAtFixedRate(wrap(job), initialDelay, period, unit);
}

代码示例来源：origin: org.rapidoid/rapidoid-ctx

public static ScheduledFuture<?> schedule(Runnable job, long delay, TimeUnit unit) {
  return scheduler().schedule(wrap(job), delay, unit);
}

代码示例来源：origin: org.rapidoid/rapidoid-ctx

public static void execute(Runnable job) {
  executor().execute(wrap(job));
}

代码示例来源：origin: org.rapidoid/rapidoid-ctx

public static ScheduledFuture<?> scheduleWithFixedDelay(Runnable job, long initialDelay, long delay, TimeUnit unit) {
  return scheduler().scheduleWithFixedDelay(wrap(job), initialDelay, delay, unit);
}