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

Schedulers.resetFactory介绍

[英]Re-apply default factory to Schedulers
[中]将默认工厂重新应用于调度程序

代码示例

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

/**
 * Re-assign the default Reactor Core {@link Schedulers} factories.
 * While the method is thread safe, its usually advised to execute such wide-impact
 * AFTER all tested code has been run (teardown etc).
 */
public static void reset() {
  VirtualTimeScheduler s = CURRENT.get();
  if (s != null && CURRENT.compareAndSet(s, null)) {
    Schedulers.resetFactory();
  }
}

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

@Override
public void dispose() {
  if (shutdown) {
    return;
  }
  queue.clear();
  shutdown = true;
  directWorker.dispose();
  //TODO remove the below behavior?
  VirtualTimeScheduler s = CURRENT.get();
  if (s != null && s == this && CURRENT.compareAndSet(s, null)) {
    Schedulers.resetFactory();
  }
}

代码示例来源：origin: spring-cloud/spring-cloud-sleuth

@PreDestroy
public void cleanupHooks() {
  if (log.isTraceEnabled()) {
    log.trace("Cleaning up hooks");
  }
  Hooks.resetOnLastOperator(SLEUTH_TRACE_REACTOR_KEY);
  Schedulers.resetFactory();
}

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

@After
public void resetSchedulers() {
  Schedulers.resetFactory();
  Schedulers.DECORATORS.clear();
}

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

@Test
public void testOverride() throws InterruptedException {
  TestSchedulers ts = new TestSchedulers(true);
  Schedulers.setFactory(ts);
  Assert.assertEquals(ts.single, Schedulers.newSingle("unused"));
  Assert.assertEquals(ts.elastic, Schedulers.newElastic("unused"));
  Assert.assertEquals(ts.parallel, Schedulers.newParallel("unused"));
  Schedulers.resetFactory();
  Scheduler s = Schedulers.newSingle("unused");
  s.dispose();
  Assert.assertNotSame(ts.single, s);
}

代码示例来源：origin: io.projectreactor/reactor-test

/**
 * Re-assign the default Reactor Core {@link Schedulers} factories.
 * While the method is thread safe, its usually advised to execute such wide-impact
 * AFTER all tested code has been run (teardown etc).
 */
public static void reset() {
  VirtualTimeScheduler s = CURRENT.get();
  if (s != null && CURRENT.compareAndSet(s, null)) {
    Schedulers.resetFactory();
  }
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-sleuth-core

@PreDestroy
public void cleanupHooks() {
  if (log.isTraceEnabled()) {
    log.trace("Cleaning up hooks");
  }
  Hooks.resetOnLastOperator(SLEUTH_TRACE_REACTOR_KEY);
  Schedulers.resetFactory();
}

代码示例来源：origin: io.projectreactor/reactor-test

@Override
public void dispose() {
  if (shutdown) {
    return;
  }
  queue.clear();
  shutdown = true;
  directWorker.dispose();
  //TODO remove the below behavior?
  VirtualTimeScheduler s = CURRENT.get();
  if (s != null && s == this && CURRENT.compareAndSet(s, null)) {
    Schedulers.resetFactory();
  }
}