Java 类io.vertx.core.impl.ConcurrentHashSet 实例源码

项目:vertx-zero    文件:EndPointTc.java   
@Test
public void testEndPoint(final TestContext context) {
    final Set<Event> all = new ConcurrentHashSet<>();
    all.addAll(extractor().extract(ED1.class));
    all.addAll(extractor().extract(ED.class));
    for (final Event event : all) {
        getLogger().info("[TEST] Extract event: {0}.", event);
    }
}
项目:vertx-zero    文件:ChoosableSet.java   
public ChoosableSet(final int initialSize) {
    this.ids = new ConcurrentHashSet<>(initialSize);
}
项目:vert.3x-gateway    文件:ChoosableSet.java   
public ChoosableSet(int initialSize) {
  ids = new ConcurrentHashSet<>(initialSize);
}
项目:vertx-infinispan    文件:InfinispanAsyncMultiMap.java   
public ChoosableSet(int initialSize) {
  ids = new ConcurrentHashSet<>(initialSize);
}
项目:vertx-hazelcast    文件:ChoosableSet.java   
public ChoosableSet(int initialSize) {
  ids = new ConcurrentHashSet<>(initialSize);
}