Java 类java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock 实例源码

项目：alfresco-object-storage-connectors 文件：ObjectStorageContentStore.java

@Override
public ContentReader getReader(String contentUrl) {
    if (logger.isDebugEnabled()) {
        logger.debug(String.format("Content Reader for %s", contentUrl));
    }

    // Use pool of locks - which one is determined by a hash of the URL.
    // This will stop the content from being read/cached multiple times from
    // the backing store
    // when it should only be read once - cached versions should be returned
    // after that.
    ReadLock readLock = readWriteLock(contentUrl).readLock();
    readLock.lock();
    try {
        return this.objectStorageService.getReader(contentUrl);
    } catch (IOException e) {
        logger.error(e.getMessage(), e);
    } finally {
        readLock.unlock();
    }

    return null;
}

项目：alfresco-repository 文件：InMemoryCacheStatistics.java

@Override
public long count(String cacheName, OpType opType)
{
    ReadLock readLock = getReadLock(cacheName);
    readLock.lock();
    try
    {
        Map<OpType, OperationStats> cacheStats = cacheToStatsMap.get(cacheName);
        if (cacheStats == null)
        {
            throw new NoStatsForCache(cacheName);
        }
        OperationStats opStats = cacheStats.get(opType);
        return opStats.getCount();
    }
    finally
    {
        readLock.unlock();
    }
}

项目：alfresco-repository 文件：InMemoryCacheStatistics.java

@Override
public double meanTime(String cacheName, OpType opType)
{
    ReadLock readLock = getReadLock(cacheName);
    readLock.lock();
    try
    {
        Map<OpType, OperationStats> cacheStats = cacheToStatsMap.get(cacheName);
        if (cacheStats == null)
        {
            throw new NoStatsForCache(cacheName);
        }
        OperationStats opStats = cacheStats.get(opType);
        return opStats.meanTime();
    }
    finally
    {
        readLock.unlock();
    }
}

项目：alfresco-repository 文件：InMemoryCacheStatistics.java

@Override
public double hitMissRatio(String cacheName)
{
    ReadLock readLock = getReadLock(cacheName);
    readLock.lock();
    try
    {
        Map<OpType, OperationStats> cacheStats = cacheToStatsMap.get(cacheName);
        if (cacheStats == null)
        {
            throw new NoStatsForCache(cacheName);
        }
        long hits = cacheStats.get(OpType.GET_HIT).getCount();
        long misses = cacheStats.get(OpType.GET_MISS).getCount();
        return (double)hits / (hits+misses);
    }
    finally
    {
        readLock.unlock();
    }
}

项目：alfresco-repository 文件：InMemoryCacheStatistics.java

@Override
public long numGets(String cacheName)
{
    ReadLock readLock = getReadLock(cacheName);
    readLock.lock();
    try
    {
        Map<OpType, OperationStats> cacheStats = cacheToStatsMap.get(cacheName);
        if (cacheStats == null)
        {
            throw new NoStatsForCache(cacheName);
        }
        long hits = cacheStats.get(OpType.GET_HIT).getCount();
        long misses = cacheStats.get(OpType.GET_MISS).getCount();
        return hits+misses;
    }
    finally
    {
        readLock.unlock();
    }
}

项目：alfresco-repository 文件：InMemoryCacheStatistics.java

@Override
public Map<OpType, OperationStats> allStats(String cacheName)
{
    ReadLock readLock = getReadLock(cacheName);
    readLock.lock();
    try
    {
        Map<OpType, OperationStats> cacheStats = cacheToStatsMap.get(cacheName);
        if (cacheStats == null)
        {
            throw new NoStatsForCache(cacheName);
        }
        return new HashMap<>(cacheStats);
    }
    finally
    {
        readLock.unlock();
    }
}

项目：k8s-proxy 文件：K8sReverseProxy.java

@RequestMapping("/get_token")
@ResponseBody
public TokenInfo getTokens(HttpServletRequest request, HttpServletResponse response)
        throws ClientProtocolException,
            IOException
{
    if (googleToken == null || googleToken.getIdToken() == null || googleToken.getRefreshToken() == null) {
        initialRedirect = request.getRequestURI().toString();
        response.sendRedirect(googleTokenRetriever.getAuthorizeUrl());
        return null;
    }

    ReadLock readLock = lock.readLock();
    try {
        readLock.lock();
        return new TokenInfo().withIdToken(googleToken.getIdToken())
                              .withRefreshToken(googleToken.getRefreshToken());
    } finally {
        readLock.unlock();
    }
}

项目：cloud-bigtable-client 文件：BigtableBufferedMutator.java

@Override
public void mutate(List<? extends Mutation> mutations) throws IOException {
  // Ensure that close() or flush() aren't current being called.
  ReadLock lock = mutationLock.readLock();
  lock.lock();
  try {
    if (closed) {
      throw new IllegalStateException("Cannot mutate when the BufferedMutator is closed.");
    }
    handleExceptions();
    for (Mutation mutation : mutations) {
      doMutation(mutation);
    }
  } finally {
    lock.unlock();
  }
}