• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java DeterministicScheduler类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.jmock.lib.concurrent.DeterministicScheduler的典型用法代码示例。如果您正苦于以下问题:Java DeterministicScheduler类的具体用法?Java DeterministicScheduler怎么用?Java DeterministicScheduler使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



DeterministicScheduler类属于org.jmock.lib.concurrent包,在下文中一共展示了DeterministicScheduler类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testStartSuddenDeath

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test
public void testStartSuddenDeath() {
    DeterministicScheduler scheduler = new DeterministicScheduler();
    DeterministicStopWatch stopWatch = new DeterministicStopWatch();
    List<Message> messages = new ArrayList<>();

    SuddenDeath suddenDeath = new SuddenDeath(50, 5, 11, new InternalScheduler(scheduler, stopWatch), messages::add);
    suddenDeath.onStartGame(emptyList());

    stopWatch.setTime(60 * 1000);
    scheduler.tick(300, TimeUnit.MILLISECONDS);
    scheduler.tick(5001, TimeUnit.MILLISECONDS);

    assertThat(messages).containsExactly(
        GmsgMessage.of(format(SuddenDeath.START_MESSAGE_TEMPLATE, 11, 5)),
        ClassicStyleAddMessage.of(0, 4),
        ClassicStyleAddMessage.of(0, 4),
        ClassicStyleAddMessage.of(0, 2),
        ClassicStyleAddMessage.of(0, 1),
        ClassicStyleAddMessage.of(0, 4),
        ClassicStyleAddMessage.of(0, 4),
        ClassicStyleAddMessage.of(0, 2),
        ClassicStyleAddMessage.of(0, 1)
    );
}
 
开发者ID:nosceon,项目名称:tenorite,代码行数:26,代码来源:SuddenDeathTest.java


示例2: testStopSuddenDeathBeforeDelay

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test
public void testStopSuddenDeathBeforeDelay() {
    DeterministicScheduler scheduler = new DeterministicScheduler();
    DeterministicStopWatch stopWatch = new DeterministicStopWatch();
    List<Message> messages = new ArrayList<>();

    SuddenDeath suddenDeath = new SuddenDeath(50, 5, 11, new InternalScheduler(scheduler, stopWatch), messages::add);
    suddenDeath.onStartGame(emptyList());

    stopWatch.setTime(60 * 1000);
    scheduler.tick(300, TimeUnit.MILLISECONDS);

    suddenDeath.onEndGame();
    messages.clear();

    scheduler.tick(5001, TimeUnit.MILLISECONDS);

    assertThat(messages).isEmpty();
}
 
开发者ID:nosceon,项目名称:tenorite,代码行数:20,代码来源:SuddenDeathTest.java


示例3: testAddReloadBasicsConfig

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test(timeout = 60000)
public void testAddReloadBasicsConfig() throws Exception {
    PropertiesWriter writer = new PropertiesWriter();
    DeterministicScheduler mockScheduler = new DeterministicScheduler();
    FileConfigurationBuilder builder = new PropertiesConfigurationBuilder(writer.getFile().toURI().toURL());
    ConcurrentConstConfiguration conf = new ConcurrentConstConfiguration(new DistributedLogConfiguration());
    List<FileConfigurationBuilder> fileConfigBuilders = Lists.newArrayList(builder);
    ConfigurationSubscription confSub =
            new ConfigurationSubscription(conf, fileConfigBuilders, mockScheduler, 100, TimeUnit.MILLISECONDS);
    assertEquals(null, conf.getProperty("prop1"));

    // add
    writer.setProperty("prop1", "1");
    writer.save();
    // ensure the file change reloading event can be triggered
    ensureConfigReloaded();
    mockScheduler.tick(100, TimeUnit.MILLISECONDS);
    assertEquals("1", conf.getProperty("prop1"));

}
 
开发者ID:twitter,项目名称:distributedlog,代码行数:21,代码来源:TestConfigurationSubscription.java


示例4: testInitialConfigLoad

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test(timeout = 60000)
public void testInitialConfigLoad() throws Exception {
    PropertiesWriter writer = new PropertiesWriter();
    writer.setProperty("prop1", "1");
    writer.setProperty("prop2", "abc");
    writer.setProperty("prop3", "123.0");
    writer.setProperty("prop4", "11132");
    writer.setProperty("prop5", "true");
    writer.save();

    ScheduledExecutorService mockScheduler = new DeterministicScheduler();
    FileConfigurationBuilder builder = new PropertiesConfigurationBuilder(writer.getFile().toURI().toURL());
    ConcurrentConstConfiguration conf = new ConcurrentConstConfiguration(new DistributedLogConfiguration());
    List<FileConfigurationBuilder> fileConfigBuilders = Lists.newArrayList(builder);
    ConfigurationSubscription confSub =
            new ConfigurationSubscription(conf, fileConfigBuilders, mockScheduler, 100, TimeUnit.MILLISECONDS);
    assertEquals(1, conf.getInt("prop1"));
    assertEquals("abc", conf.getString("prop2"));
    assertEquals(123.0, conf.getFloat("prop3"), 0);
    assertEquals(11132, conf.getInt("prop4"));
    assertEquals(true, conf.getBoolean("prop5"));
}
 
开发者ID:twitter,项目名称:distributedlog,代码行数:23,代码来源:TestConfigurationSubscription.java


示例5: setup

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Before
public void setup() throws Exception {
  memoryPoolBeans.clear();

  doReturn(0L).when(configuration).getCheckIntervalInMillis();

  doReturn(heapMemoryUsage).when(memoryBean).getHeapMemoryUsage();

  scheduler = spy(new DeterministicScheduler());
  doReturn(Collections.emptyList()).when(scheduler).shutdownNow();

  subject = spy(new MBeanMonitor(heapDumpCreator, configuration,
      new Callable<ScheduledExecutorService>() {
        @Override
        public ScheduledExecutorService call() throws Exception {
          return scheduler;
        }
      }, logger) {
    @Override
    MemoryMXBean getMemoryMxBean() {
      return memoryBean;
    }

    @Override
    List<MemoryPoolMXBean> getMemoryPoolMxBeans() {
      return memoryPoolBeans;
    }
  });

  doReturn(jvm).when(subject).findCurrentJvm();
}
 
开发者ID:SAP,项目名称:java-memory-assistant,代码行数:32,代码来源:MBeanMonitorTest.java


示例6: testWarningMessage

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test
public void testWarningMessage() {
    DeterministicScheduler scheduler = new DeterministicScheduler();
    DeterministicStopWatch stopWatch = new DeterministicStopWatch();
    List<Message> messages = new ArrayList<>();

    SuddenDeath suddenDeath = new SuddenDeath(50, 5, 7, new InternalScheduler(scheduler, stopWatch), messages::add);
    suddenDeath.onStartGame(emptyList());

    stopWatch.setTime(20 * 1000);
    scheduler.tick(300, TimeUnit.MILLISECONDS);

    assertThat(messages).containsExactly(GmsgMessage.of("WARNING! Sudden death will begin in 30 seconds"));
}
 
开发者ID:nosceon,项目名称:tenorite,代码行数:15,代码来源:SuddenDeathTest.java


示例7: setUp

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Before
public void setUp() {
  executor = new DeterministicScheduler();
}
 
开发者ID:spotify,项目名称:completable-futures,代码行数:5,代码来源:CompletableFuturesTest.java


示例8: testExceptionInConfigLoad

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test(timeout = 60000)
public void testExceptionInConfigLoad() throws Exception {
    PropertiesWriter writer = new PropertiesWriter();
    writer.setProperty("prop1", "1");
    writer.save();

    DeterministicScheduler mockScheduler = new DeterministicScheduler();
    FileConfigurationBuilder builder = new PropertiesConfigurationBuilder(writer.getFile().toURI().toURL());
    ConcurrentConstConfiguration conf = new ConcurrentConstConfiguration(new DistributedLogConfiguration());
    List<FileConfigurationBuilder> fileConfigBuilders = Lists.newArrayList(builder);
    ConfigurationSubscription confSub =
            new ConfigurationSubscription(conf, fileConfigBuilders, mockScheduler, 100, TimeUnit.MILLISECONDS);

    final AtomicInteger count = new AtomicInteger(1);
    conf.addConfigurationListener(new ConfigurationListener() {
        @Override
        public void configurationChanged(ConfigurationEvent event) {
            LOG.info("config changed {}", event);
            // Throw after so we actually see the update anyway.
            if (!event.isBeforeUpdate()) {
                count.getAndIncrement();
                throw new RuntimeException("config listener threw and exception");
            }
        }
    });

    int i = 0;
    int initial = 0;
    while (count.get() == initial) {
        writer.setProperty("prop1", Integer.toString(i++));
        writer.save();
        mockScheduler.tick(100, TimeUnit.MILLISECONDS);
    }

    initial = count.get();
    while (count.get() == initial) {
        writer.setProperty("prop1", Integer.toString(i++));
        writer.save();
        mockScheduler.tick(100, TimeUnit.MILLISECONDS);
    }
}
 
开发者ID:twitter,项目名称:distributedlog,代码行数:42,代码来源:TestConfigurationSubscription.java


示例9: testSimple

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Test
public void testSimple() throws Exception {
  HostAndPort hostNameA = HostAndPort.fromString("a:1");
  HostAndPort hostNameB = HostAndPort.fromString("b:1");
  HostAndPort hostNameC = HostAndPort.fromString("c:1");
  HostAndPort hostNameD = HostAndPort.fromString("d:1");

  DnsSrvResolver resolver = Mockito.mock(DnsSrvResolver.class);

  // Run shutdown code immediately
  DeterministicScheduler executor = new DeterministicScheduler();

  final Map<HostAndPort, FakeRawMemcacheClient> knownClients = Maps.newHashMap();

  SrvKetamaClient.Connector connector = input -> {
    FakeRawMemcacheClient fakeRawMemcacheClient = new FakeRawMemcacheClient();
    knownClients.put(input, fakeRawMemcacheClient);
    return fakeRawMemcacheClient;
  };

  SrvKetamaClient ketamaClient = new SrvKetamaClient(
          "the-srv-record", resolver, executor, 1000, TimeUnit.MILLISECONDS,
          connector, 1000, TimeUnit.MILLISECONDS);
  executor.tick(1000, TimeUnit.SECONDS);

  assertFalse(ketamaClient.isConnected());

  Mockito.when(resolver.resolve(Mockito.anyString()))
          .thenReturn(ImmutableList.of(result("a"), result("b")));
  ketamaClient.updateDNS();
  executor.tick(1000, TimeUnit.SECONDS);

  assertTrue(ketamaClient.isConnected());
  assertTrue(knownClients.get(hostNameA).isConnected());
  assertTrue(knownClients.get(hostNameB).isConnected());

  Mockito.when(resolver.resolve(Mockito.anyString()))
          .thenReturn(ImmutableList.of(result("b"), result("c")));
  ketamaClient.updateDNS();
  executor.tick(1000, TimeUnit.SECONDS);

  assertTrue(ketamaClient.isConnected());
  assertFalse(knownClients.get(hostNameA).isConnected());
  assertTrue(knownClients.get(hostNameB).isConnected());
  assertTrue(knownClients.get(hostNameC).isConnected());

  Mockito.when(resolver.resolve(Mockito.anyString()))
      .thenReturn(ImmutableList.of(result("c"), result("d")));
  ketamaClient.updateDNS();
  executor.tick(1000, TimeUnit.SECONDS);

  assertTrue(ketamaClient.isConnected());
  assertFalse(knownClients.get(hostNameA).isConnected());
  assertFalse(knownClients.get(hostNameB).isConnected());
  assertTrue(knownClients.get(hostNameC).isConnected());
  assertTrue(knownClients.get(hostNameD).isConnected());

  ketamaClient.shutdown();
}
 
开发者ID:spotify,项目名称:folsom,代码行数:60,代码来源:SrvKetamaClientTest.java


示例10: setUp

import org.jmock.lib.concurrent.DeterministicScheduler; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
  scheduler = new DeterministicScheduler();
}
 
开发者ID:spotify,项目名称:futures-extra,代码行数:5,代码来源:TimeoutFutureTest.java



注:本文中的org.jmock.lib.concurrent.DeterministicScheduler类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java PluginEnableEvent类代码示例发布时间:2022-05-22
下一篇:
Java BaseSpringSystem类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap