import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Test
public void testAsyncWithNamespace() {
    String namespace = "namespace-123";

    AsyncMemcacheService ams = MemcacheServiceFactory.getAsyncMemcacheService(namespace);

    String key = "some-random-key";
    String value = "some-random-value";

    waitOnFuture(ams.put(key, value));

    // non-namespaced lookup
    Assert.assertFalse(memcache.contains(key));

    MemcacheService ms = MemcacheServiceFactory.getMemcacheService(namespace);
    Assert.assertEquals(value, ms.get(key));
}
 

import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Override
protected void putBlobIntoCache(String generatedKey, I_Blob blob) throws BlobException
{
	AsyncMemcacheService memCache = MemcacheServiceFactory.getAsyncMemcacheService();
	
	byte[] blobBytes = U_Blob.convertToBytes(blob);
	
	try
	{
		memCache.put(generatedKey, blobBytes, null, MemcacheService.SetPolicy.SET_ALWAYS);
	}
	catch(Exception e)
	{
		s_logger.log(Level.WARNING, "Could not put value into memcache.", e);
	}
}
 

import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Override
public void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException,
    ServletException {
  String path = req.getRequestURI();
  if (path.startsWith("/favicon.ico")) {
    return; // ignore the request for favicon.ico
  }

  // [START example]
  AsyncMemcacheService asyncCache = MemcacheServiceFactory.getAsyncMemcacheService();
  asyncCache.setErrorHandler(ErrorHandlers.getConsistentLogAndContinue(Level.INFO));
  String key = "count-async";
  byte[] value;
  long count = 1;
  Future<Object> futureValue = asyncCache.get(key); // Read from cache.
  // ... Do other work in parallel to cache retrieval.
  try {
    value = (byte[]) futureValue.get();
    if (value == null) {
      value = BigInteger.valueOf(count).toByteArray();
      asyncCache.put(key, value);
    } else {
      // Increment value
      count = new BigInteger(value).longValue();
      count++;
      value = BigInteger.valueOf(count).toByteArray();
      // Put back in cache
      asyncCache.put(key, value);
    }
  } catch (InterruptedException | ExecutionException e) {
    throw new ServletException("Error when waiting for future value", e);
  }
  // [END example]

  // Output content
  resp.setContentType("text/plain");
  resp.getWriter().print("Value is " + count + "\n");
}
 

import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Override
protected void deleteBlobFromCache(String generatedKey) throws BlobException
{
	AsyncMemcacheService memCache = MemcacheServiceFactory.getAsyncMemcacheService();
	
	try
	{
		memCache.delete(generatedKey);
	}
	catch(Exception e)
	{
		s_logger.log(Level.WARNING, "Could not delete value from memcache.", e);
	}
}
 

import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Override
protected void deleteBlobsFromCache(Map<I_BlobKey, Class<? extends I_Blob>> values) throws BlobException
{
	AsyncMemcacheService memCache = MemcacheServiceFactory.getAsyncMemcacheService();
	
	ArrayList<String> keys = null;
	
	Iterator<I_BlobKey> iterator = values.keySet().iterator();
	while( iterator.hasNext() )
	{
		I_BlobKey keySource = iterator.next();
		I_Blob blob = m_templateMngr.getTemplate(values.get(keySource));
		
		if( !isCacheable(blob) )
		{
			continue;
		}
			
		keys = keys != null ? keys : new ArrayList<String>();
		
		keys.add(keySource.createBlobKey(blob));
	}
	
	if( keys == null )  return;

	try
	{
		memCache.deleteAll(keys);
	}
	catch(Exception e)
	{
		s_logger.log(Level.WARNING, "Could not delete batch from memcache.", e);
	}
}
 

import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Override
protected void putBlobsIntoCache(Map<I_BlobKey, I_Blob> values) throws BlobException
{
	HashMap<String, byte[]> entries = null;
	
	Iterator<I_BlobKey> iterator = values.keySet().iterator();
	while( iterator.hasNext() )
	{
		I_BlobKey keySource = iterator.next();
		I_Blob blob = values.get(keySource);
		
		if( !isCacheable(blob) )
		{
			continue;
		}
			
		entries = entries != null ? entries : new HashMap<String, byte[]>();
		
		byte[] blobBytes = U_Blob.convertToBytes(blob);
		entries.put(keySource.createBlobKey(blob), blobBytes);
	}
	
	if( entries == null )  return;
	
	AsyncMemcacheService memCache = MemcacheServiceFactory.getAsyncMemcacheService();
	
	try
	{
		memCache.putAll(entries, null);
	}
	catch(Exception e)
	{
		s_logger.log(Level.WARNING, "Could not put batch into memcache.", e);
	}
}
 

import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Deprecated
public static AsyncMemcacheService getInstance() {
  return MemcacheServiceFactory.getAsyncMemcacheService();
}