Java 类com.google.common.util.concurrent.Striped 实例源码

@Inject
public FeedRefreshUpdater(SessionFactory sessionFactory, FeedUpdateService feedUpdateService, PubSubService pubSubService,
        FeedQueues queues, CommaFeedConfiguration config, MetricRegistry metrics, FeedSubscriptionDAO feedSubscriptionDAO,
        CacheService cache) {
    this.sessionFactory = sessionFactory;
    this.feedUpdateService = feedUpdateService;
    this.pubSubService = pubSubService;
    this.queues = queues;
    this.config = config;
    this.feedSubscriptionDAO = feedSubscriptionDAO;
    this.cache = cache;

    ApplicationSettings settings = config.getApplicationSettings();
    int threads = Math.max(settings.getDatabaseUpdateThreads(), 1);
    pool = new FeedRefreshExecutor("feed-refresh-updater", threads, Math.min(50 * threads, 1000), metrics);
    locks = Striped.lazyWeakLock(threads * 100000);

    entryCacheMiss = metrics.meter(MetricRegistry.name(getClass(), "entryCacheMiss"));
    entryCacheHit = metrics.meter(MetricRegistry.name(getClass(), "entryCacheHit"));
    feedUpdated = metrics.meter(MetricRegistry.name(getClass(), "feedUpdated"));
    entryInserted = metrics.meter(MetricRegistry.name(getClass(), "entryInserted"));
}

public Oplog(RowUpdateFactory rowUpdateFactory) {
    this.locks = Striped.lock(GlobalContext.getLockPoolSize());
    this.oplogPartitionMaps = new ArrayList<>();
    for (int i = 0; i < GlobalContext.getNumLocalCommChannels(); i++) {
        this.oplogPartitionMaps.add(new TIntObjectHashMap<OplogPartition>());
        ArrayList<Integer> serverIds = GlobalContext.getServerThreadIDs(i);
        for (int serverId : serverIds) {
            this.oplogPartitionMaps.get(i).put(serverId,
                    new SparseOplogPartition(rowUpdateFactory));
        }
    }
}

@Inject
UnfiredCandidateActions(BrowserConfiguration config, Provider<StateFlowGraph> sfg,
        MetricRegistry registry) {
    this.sfg = sfg;
    cache = Maps.newHashMap();
    statesWithCandidates = Queues.newLinkedBlockingQueue();
    // Every browser gets a lock.
    locks = Striped.lock(config.getNumberOfBrowsers());

    crawlerLostCount =
            registry.register(MetricsModule.EVENTS_PREFIX + "crawler_lost", new Counter());
    unfiredActionsCount =
            registry.register(MetricsModule.EVENTS_PREFIX + "unfired_actions", new Counter());
}

public StripedLocks(int stripesCount) {
  striped = Striped.readWriteLock(stripesCount);
}

public DefaultBrokerCache() {
  this.sharedResourceCache = CacheBuilder.newBuilder().build();
  this.autoScopeCache = CacheBuilder.newBuilder().build();
  this.invalidationLock = Striped.lazyWeakLock(20);
}

public StripedKeyedLocker(int stripes) {
  locks = Striped.readWriteLock(stripes);
}