本文整理汇总了Java中com.google.appengine.api.memcache.AsyncMemcacheService类的典型用法代码示例。如果您正苦于以下问题:Java AsyncMemcacheService类的具体用法?Java AsyncMemcacheService怎么用?Java AsyncMemcacheService使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
AsyncMemcacheService类属于com.google.appengine.api.memcache包,在下文中一共展示了AsyncMemcacheService类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testAsyncWithNamespace
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));
}
开发者ID:GoogleCloudPlatform,项目名称:appengine-tck,代码行数:18,代码来源:MemcacheAsync2Test.java
示例2: putBlobIntoCache
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);
}
}
开发者ID:dougkoellmer,项目名称:swarm,代码行数:17,代码来源:BlobManager_MemCache.java
示例3: doGet
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");
}
开发者ID:GoogleCloudPlatform,项目名称:java-docs-samples,代码行数:39,代码来源:MemcacheAsyncCacheServlet.java
示例4: deleteBlobFromCache
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);
}
}
开发者ID:dougkoellmer,项目名称:swarm,代码行数:15,代码来源:BlobManager_MemCache.java
示例5: deleteBlobsFromCache
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);
}
}
开发者ID:dougkoellmer,项目名称:swarm,代码行数:35,代码来源:BlobManager_MemCache.java
示例6: putBlobsIntoCache
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);
}
}
开发者ID:dougkoellmer,项目名称:swarm,代码行数:36,代码来源:BlobManager_MemCache.java
示例7: getInstance
import com.google.appengine.api.memcache.AsyncMemcacheService; //导入依赖的package包/类
@Deprecated
public static AsyncMemcacheService getInstance() {
return MemcacheServiceFactory.getAsyncMemcacheService();
}
开发者ID:csavelief,项目名称:gwt-sandbox,代码行数:5,代码来源:LowLevelMemcacheAsync.java
注:本文中的com.google.appengine.api.memcache.AsyncMemcacheService类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论