com.google.common.collect.MutableClassToInstanceMap的实例源码

项目：FinanceAnalytics    文件：ComponentMapProvider.java   

@Override
public ComponentMap get() {

  ClasstoInstanceMap<Object> components = MutableClasstoInstanceMap.create();

  components.putInstance(HolidaySource.class,_holidaySource);
  components.putInstance(ConfigSource.class,_configSource);
  components.putInstance(HistoricalTimeSeriesSource.class,_htsSource);
  components.putInstance(ConventionBundleSource.class,_conventionBundleSource);
  components.putInstance(HistoricalTimeSeriesResolver.class,_htsResolver);
  components.putInstance(SecuritySource.class,_securitySource);
  components.putInstance(ConventionSource.class,_conventionSource);
  components.putInstance(RegionSource.class,_regionSource);
  components.putInstance(PositionSource.class,_positionSource);
  components.putInstance(MarketDataSnapshotSource.class,_snapshotSource);
  components.putInstance(LegalEntitySource.class,_legalEntitySource);
  components.putInstance(ExchangeSource.class,_exchangeSource);

  ComponentMap componentMap = ComponentMap.of(components);
  ServiceContext serviceContext = ServiceContext.of(componentMap.getComponents())
      .with(VersionCorrectionProvider.class,new FixedInstantVersionCorrectionProvider(Instant.Now()));
  ThreadLocalServiceContext.init(serviceContext);

  return componentMap;
}

项目：java-util-examples    文件：ClasstoInstanceMapExample.java   

@Test
public void classtoINstanceMap_example () {

    Person person = new Person("Jackson");
    Jobs jobs = new Jobs("IT person");
    Address address = new  Address("505 Williams Street");

    ClasstoInstanceMap<Object> classtoInstanceMap = MutableClasstoInstanceMap.create();
    classtoInstanceMap.put(Person.class,person);
    classtoInstanceMap.put(Jobs.class,jobs);
    classtoInstanceMap.put(Address.class,address);

    logger.info(classtoInstanceMap);

    assertEquals("IT person",classtoInstanceMap.getInstance(Jobs.class).getJobName());
}

项目：bazel    文件：BuildConfiguration.java   

/**
 * Returns a copy of this configuration only including the given fragments (which the current
 * configuration is assumed to have).
 */
public BuildConfiguration clone(
    FragmentClassSet fragmentClasses,RuleClassprovider ruleClassprovider) {

  ClasstoInstanceMap<Fragment> fragmentsMap = MutableClasstoInstanceMap.create();
  for (Fragment fragment : fragments.values()) {
    if (fragmentClasses.fragmentClasses().contains(fragment.getClass())) {
      fragmentsMap.put(fragment.getClass(),fragment);
    }
  }
  BuildOptions options = buildOptions.trim(
      getoptionsClasses(fragmentsMap.keySet(),ruleClassprovider));
  BuildConfiguration newConfig =
      new BuildConfiguration(
          directories,fragmentsMap,options,mainRepositoryName.strippedname());
  return newConfig;
}

项目：levelup-java-examples    文件：ClasstoInstanceMapExample.java   

@Test
public void classtoINstanceMap_example () {

    Person person = new Person("Jackson");
    Jobs jobs = new Jobs("IT person");
    Address address = new  Address("505 Williams Street");

    ClasstoInstanceMap<Object> classtoInstanceMap = MutableClasstoInstanceMap.create();
    classtoInstanceMap.put(Person.class,classtoInstanceMap.getInstance(Jobs.class).getJobName());
}

项目：GitHub    文件：StaticEnvironment.java   

void init(Set<? extends TypeElement> annotations,RoundEnvironment round,ProcessingEnvironment processing) {
  this.components = MutableClasstoInstanceMap.create();
  this.processing = processing;
  this.round = round;
  this.annotations = ImmutableSet.copyOf(annotations);
  this.initialized = true;
}

项目：beam    文件：ProxyInvocationHandler.java   

private ProxyInvocationHandler(
    Map<String,BoundValue> options,Map<String,JsonNode> jsonoptions) {
  this.options = options;
  this.jsonoptions = jsonoptions;
  this.kNownInterfaces = new HashSet<>(PipelineOptionsFactory.getRegisteredOptions());
  gettersToPropertyNames = Maps.newHashMap();
  settersToPropertyNames = Maps.newHashMap();
  interfacetoProxyCache = MutableClasstoInstanceMap.create();
}

项目：guava-demo    文件：ClasstoInstanceSample.java   

public static void main(String[] args) {
    ClasstoInstanceMap<Number> numbers = MutableClasstoInstanceMap.create();

    numbers.putInstance(Integer.class,Integer.valueOf(0));
    numbers.putInstance(Double.class,Double.valueOf(1));
    numbers.putInstance(Float.class,Float.valueOf(3));

    double myNum = numbers.getInstance(Double.class);
    System.out.println(myNum);
}

项目：FinanceAnalytics    文件：MockUtils.java   

private static MutableClasstoInstanceMap<Object> doMock(List<Class<?>> classes,boolean isstrict) {

  MutableClasstoInstanceMap<Object> mocks = MutableClasstoInstanceMap.create();
  for (Class<?> clazz : classes) {
    if (isstrict) {
      mocks.put(clazz,strictMock(clazz));
    } else {
      mocks.put(clazz,mock(clazz));
    }
  }

  return mocks;
}

项目：tensorics-core    文件：ImmutableOptionRegistry.java   

private <T1 extends Option<T1>> ImmutableOptionRegistry(Collection<T> options) {
    /*
     * we first have to create a mutable map,because the collection might contain options of the same class,where
     * later ones will override prevIoUs ones. This would not be allowed by the builder of the immutable map.
     */
    ClasstoInstanceMap<T> mutableOptions = MutableClasstoInstanceMap.create();
    addToMap(mutableOptions,options);
    this.options = ImmutableClasstoInstanceMap.copyOf(mutableOptions);
}

项目：sette-tool    文件：SetteAnnotationUtils.java   

/**
 * Gets the map of SETTE annotations.
 *
 * @param element
 *            an annotated element
 * @return a map of SETTE annotations
 */
public static ClasstoInstanceMap<Annotation> getSetteAnnotations(
        @NonNull AnnotatedElement element) {
    ClasstoInstanceMap<Annotation> setteAnnots = MutableClasstoInstanceMap.create();

    Arrays.stream(element.getAnnotations())
            .filter(SetteAnnotationUtils::isSetteAnnotation)
            .forEach(a -> setteAnnots.put(a.annotationType(),a));

    return setteAnnots;
}

项目：OpenBMLParser    文件：BehavIoUrBlock.java   

public BehavIoUrBlock(BMLBehaviorAttributeExtension... bmlBehaviorAttributeExtensions)
{
    this.bmlBehaviorAttributeExtensions = MutableClasstoInstanceMap.create();
    for (BMLBehaviorAttributeExtension ext : bmlBehaviorAttributeExtensions)
    {
        this.bmlBehaviorAttributeExtensions.put(ext.getClass(),ext);
    }
    requiredBlocks = new ArrayList<requiredBlock>();
    constraintBlocks = new ArrayList<ConstraintBlock>();
    behavIoUrs = new ArrayList<BehavIoUr>();
}

项目：immutables    文件：StaticEnvironment.java   

void init(Set<? extends TypeElement> annotations,ProcessingEnvironment processing) {
  this.components = MutableClasstoInstanceMap.create();
  this.processing = processing;
  this.round = round;
  this.annotations = ImmutableSet.copyOf(annotations);
  this.initialized = true;
}

项目：rigel    文件：ContentItemFactory.java   

public <T extends ContentItem> ImmutableList<T> fromresponse(QueryResponse response,ContentItem.Schema<T> forcedSchema,FieldSet... additionalFields) {
    ClasstoInstanceMap<FieldDataSource<?>> context = MutableClasstoInstanceMap.create();
    context.put(QueryResponseDataSource.class,new QueryResponseDataSource(response));

    Builder<T> builder = ImmutableList.builder();
    for(SolrDocument doc : response.getResults()) {
        context.put(SolrDocDataSource.class,new SolrDocDataSource(doc));
        context.put(SchemaDataSource.class,new SchemaDataSource(forcedSchema));
        builder.add(buildItem(forcedSchema,context,additionalFields));
    }
    return builder.build();
}

项目：rigel    文件：ContentItemFactory.java   

public <T extends ContentItem> ImmutableList<T> fromDocumentList(SolrDocumentList list,FieldSet... additionalFields) {
    ClasstoInstanceMap<FieldDataSource<?>> context = MutableClasstoInstanceMap.create();
    Builder<T> builder = ImmutableList.builder();
    for(SolrDocument doc : list) {
        context.put(SolrDocDataSource.class,additionalFields));
    }
    return builder.build();
}

项目：rigel    文件：ContentItemFactory.java   

public ImmutableList<ContentItem> fromresponse(QueryResponse response,new QueryResponseDataSource(response));

    Builder<ContentItem> builder = ImmutableList.builder();
    for(SolrDocument doc : response.getResults()) {
        ContentItem.Schema<?> schema = getSchemaForDocument(doc);
        context.put(SchemaDataSource.class,new SchemaDataSource(schema));
        context.put(SolrDocDataSource.class,new SolrDocDataSource(doc));
        builder.add(buildItem(schema,additionalFields));
    }
    return builder.build();
}

项目：rigel    文件：ContentItemFactory.java   

public ImmutableList<ContentItem> fromDocumentList(SolrDocumentList list,FieldSet... additionalFields) {
    ClasstoInstanceMap<FieldDataSource<?>> context = MutableClasstoInstanceMap.create();
    Builder<ContentItem> builder = ImmutableList.builder();
    for(SolrDocument doc : list) {
        ContentItem.Schema<?> schema = getSchemaForDocument(doc);
        context.put(SchemaDataSource.class,additionalFields));
    }
    return builder.build();
}

项目：hashsdn-controller    文件：BindingContextUtils.java   

public SingleConsumerContextImpl(ClasstoInstanceMap<BindingAwareService> serviceProvider) {
    this.alreadyRetrievedServices = MutableClasstoInstanceMap.create();
    this.serviceProvider = serviceProvider;
}

项目：hashsdn-controller    文件：DombrokerImplModule.java   

@Override
public java.lang.AutoCloseable createInstance() {
    // The services are provided via blueprint so retrieve then from the Osgi service registry for
    // backwards compatibility.

    final List<AutoCloseable> closeables = new ArrayList<>();
    DOMNotificationService domNotificationService = newTracker(
            DOMNotificationService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DOMNotificationPublishService domNotificationPublishService = newTracker(
            DOMNotificationPublishService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DomrpcService domrpcService = newTracker(
            DomrpcService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DomrpcProviderService domrpcProvider = newTracker(
            DomrpcProviderService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DOMMountPointService mountService = newTracker(DOMMountPointService.class,closeables).
            waitForService(WaitingServiceTracker.FIVE_MINUTES);

    SchemaService globalSchemaService = newTracker(SchemaService.class,closeables).
            waitForService(WaitingServiceTracker.FIVE_MINUTES);

    final DOMDatabroker databroker = getAsyncDatabrokerDependency();

    final ClasstoInstanceMap<brokerService> services = MutableClasstoInstanceMap.create();

    services.putInstance(DOMNotificationService.class,domNotificationService);
    services.putInstance(DOMNotificationPublishService.class,domNotificationPublishService);

    final SchemaService schemaService = getSchemaServiceImpl(globalSchemaService);
    services.putInstance(SchemaService.class,schemaService);

    services.putInstance(DOMDatabroker.class,databroker);

    services.putInstance(DomrpcService.class,domrpcService);
    services.putInstance(DomrpcProviderService.class,domrpcProvider);

    services.putInstance(DOMMountPointService.class,mountService);

    brokerImpl broker = new brokerImpl(domrpcService,domrpcProvider,services);
    broker.setDeactivator(() -> {
        for (AutoCloseable ac : closeables) {
            try {
                ac.close();
            } catch (Exception e) {
                LOG.warn("Exception while closing {}",ac,e);
            }
        }
    });

    return broker;
}

项目：ldp4j    文件：ServiceRegistry.java   

public ServiceRegistry() {
    this.services=MutableClasstoInstanceMap.<Service>create();
    this.builders=new LinkedHashMap<Class<?>,ServiceBuilder<?>>();
    this.delegate=RuntimeDelegate.getInstance();
}

项目：ldp4j    文件：TemplateManager.java   

private TemplateManagerBuilder() {
    this.handlerClasses=Lists.newArrayList();
    this.handlers=MutableClasstoInstanceMap.<ResourceHandler>create();
}

项目：ServerListPlus    文件：ClasstoInstanceStorage.java   

public static <B> ClasstoInstanceStorage<B> create() {
    return create(MutableClasstoInstanceMap.<B>create());
}

项目：ServerListPlus    文件：ClasstoInstanceStorage.java   

public static <B> ClasstoInstanceStorage<B> createLinked() {
    return create(MutableClasstoInstanceMap.create(new LinkedHashMap<Class<? extends B>,B>()));
}

项目：hashsdn-controller    文件：BindingTestContext.java   

private void startDombroker() {
    checkState(this.executor != null);

    this.domrouter = new DomrpcRouter();
    this.mockSchemaService.registerSchemaContextListener(this.domrouter);

    final ClasstoInstanceMap<brokerService> services = MutableClasstoInstanceMap.create();
    services.put(DomrpcService.class,this.domrouter);

    this.bibrokerImpl = new brokerImpl(this.domrouter,services);

}

项目：FinanceAnalytics    文件：MockUtils.java   

/**
 * Returns a map of mock instances,indexed by class.
 * @param classes the classes to use to mock
 * @return a map of class to mock
 */
public static MutableClasstoInstanceMap<Object> mocks(Class<?>...classes ) {
  return doMock(Arrays.asList(classes),false);
}

项目：FinanceAnalytics    文件：MockUtils.java   

/**
 * Returns a map of mock instances,indexed by class.
 * @param classes the classes to use to mock
 * @return a map of class to mock
 */
public static MutableClasstoInstanceMap<Object> mocks(List<Class<?>> classes ) {
  return doMock(classes,false);
}

项目：FinanceAnalytics    文件：MockUtils.java   

/**
 * Returns a map of strict mock instances,indexed by class.
 * @param classes the classes to use to mock
 * @return a map of class to mock
 */
public static MutableClasstoInstanceMap<Object> strictMocks(List<Class<?>> classes ) {
  return doMock(classes,true);
}

项目：FinanceAnalytics    文件：MockUtils.java   

/**
 * Returns a map of strict mock instances,indexed by class.
 * @param classes the classes to use to mock
 * @return a map of class to mock
 */
public static MutableClasstoInstanceMap<Object> strictMocks(Class<?>... classes) {
  return doMock(Arrays.asList(classes),true);
}