net.spy.memcached.MemcachedClient.asyncStore()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(196)

本文整理了Java中net.spy.memcached.MemcachedClient.asyncStore()方法的一些代码示例，展示了MemcachedClient.asyncStore()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MemcachedClient.asyncStore()方法的具体详情如下：
包路径：net.spy.memcached.MemcachedClient
类名称：MemcachedClient
方法名：asyncStore

MemcachedClient.asyncStore介绍

暂无

代码示例

代码示例来源：origin: com.google.code.maven-play-plugin.spy/spymemcached

  1. private Future<Boolean> asyncStore(StoreType storeType,
  2.     String key, int exp, Object value) {
  3.   return asyncStore(storeType, key, exp, value, transcoder);
  4. }

代码示例来源：origin: net.spy/spymemcached

  1. private OperationFuture<Boolean> asyncStore(StoreType storeType, String key,
  2.   int exp, Object value) {
  3.  return asyncStore(storeType, key, exp, value, transcoder);
  4. }

代码示例来源：origin: com.google.code.simple-spring-memcached/spymemcached

  1. private OperationFuture<Boolean> asyncStore(StoreType storeType, String key,
  2.   int exp, Object value) {
  3.  return asyncStore(storeType, key, exp, value, transcoder);
  4. }

代码示例来源：origin: com.amazonaws/elasticache-java-cluster-client

  1. private OperationFuture<Boolean> asyncStore(StoreType storeType, String key,
  2.   int exp, Object value) {
  3.  return asyncStore(storeType, key, exp, value, transcoder);
  4. }

代码示例来源：origin: naver/arcus-java-client

  1. private Future<Boolean> asyncStore(StoreType storeType,
  2.                   String key, int exp, Object value) {
  3.  return asyncStore(storeType, key, exp, value, transcoder);
  4. }

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. private Future<Boolean> asyncStore(StoreType storeType,
  2.     String key, int exp, Object value) {
  3.   return asyncStore(storeType, key, exp, value, transcoder);
  4. }

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. return asyncStore(StoreType.set, key, exp, o, tc);

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. return asyncStore(StoreType.add, key, exp, o, transcoder);

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. return asyncStore(StoreType.replace, key, exp, o, tc);

代码示例来源：origin: com.google.code.maven-play-plugin.spy/spymemcached

  1. return asyncStore(StoreType.add, key, exp, o, transcoder);

代码示例来源：origin: com.google.code.maven-play-plugin.spy/spymemcached

  1. return asyncStore(StoreType.set, key, exp, o, transcoder);

代码示例来源：origin: com.amazonaws/elasticache-java-cluster-client

  1. return asyncStore(StoreType.add, key, exp, o, transcoder);

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. return asyncStore(StoreType.add, key, exp, o, tc);

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. return asyncStore(StoreType.set, key, exp, o, transcoder);

代码示例来源：origin: com.google.code.simple-spring-memcached/spymemcached

  1. return asyncStore(StoreType.set, key, exp, o, tc);

代码示例来源：origin: com.google.code.simple-spring-memcached/spymemcached

  1. private long mutateWithDefault(Mutator t, String key, long by, long def,
  2.   int exp) {
  3.  long rv = mutate(t, key, by, def, exp);
  4.  // The ascii protocol doesn't support defaults, so I added them
  5.  // manually here.
  6.  if (rv == -1) {
  7.   Future<Boolean> f = asyncStore(StoreType.add, key, exp,
  8.     String.valueOf(def));
  9.   try {
  10.    if (f.get(operationTimeout, TimeUnit.MILLISECONDS)) {
  11.     rv = def;
  12.    } else {
  13.     rv = mutate(t, key, by, 0, exp);
  14.     assert rv != -1 : "Failed to mutate or init value";
  15.    }
  16.   } catch (InterruptedException e) {
  17.    throw new RuntimeException("Interrupted waiting for store", e);
  18.   } catch (ExecutionException e) {
  19.    throw new RuntimeException("Failed waiting for store", e);
  20.   } catch (TimeoutException e) {
  21.    throw new OperationTimeoutException("Timeout waiting to mutate or init"
  22.      + " value", e);
  23.   }
  24.  }
  25.  return rv;
  26. }

代码示例来源：origin: com.google.code.maven-play-plugin.spy/spymemcached

  1. private long mutateWithDefault(Mutator t, String key,
  2.     int by, long def, int exp) {
  3.   long rv=mutate(t, key, by, def, exp);
  4.   // The ascii protocol doesn't support defaults, so I added them
  5.   // manually here.
  6.   if(rv == -1) {
  7.     Future<Boolean> f=asyncStore(StoreType.add,
  8.         key, exp, String.valueOf(def));
  9.     try {
  10.       if(f.get(operationTimeout, TimeUnit.MILLISECONDS)) {
  11.         rv=def;
  12.       } else {
  13.         rv=mutate(t, key, by, 0, exp);
  14.         assert rv != -1 : "Failed to mutate or init value";
  15.       }
  16.     } catch (InterruptedException e) {
  17.       throw new RuntimeException("Interrupted waiting for store", e);
  18.     } catch (ExecutionException e) {
  19.       throw new RuntimeException("Failed waiting for store", e);
  20.     } catch (TimeoutException e) {
  21.       throw new OperationTimeoutException(
  22.         "Timeout waiting to mutate or init value", e);
  23.     }
  24.   }
  25.   return rv;
  26. }

代码示例来源：origin: com.google.code.maven-play-plugin.spy/memcached

  1. private long mutateWithDefault(Mutator t, String key,
  2.     int by, long def, int exp) {
  3.   long rv=mutate(t, key, by, def, exp);
  4.   // The ascii protocol doesn't support defaults, so I added them
  5.   // manually here.
  6.   if(rv == -1) {
  7.     Future<Boolean> f=asyncStore(StoreType.add,
  8.         key, exp, String.valueOf(def));
  9.     try {
  10.       if(f.get(operationTimeout, TimeUnit.MILLISECONDS)) {
  11.         rv=def;
  12.       } else {
  13.         rv=mutate(t, key, by, 0, exp);
  14.         assert rv != -1 : "Failed to mutate or init value";
  15.       }
  16.     } catch (InterruptedException e) {
  17.       throw new RuntimeException("Interrupted waiting for store", e);
  18.     } catch (ExecutionException e) {
  19.       throw new RuntimeException("Failed waiting for store", e);
  20.     } catch (TimeoutException e) {
  21.       throw new OperationTimeoutException(
  22.         "Timeout waiting to mutate or init value", e);
  23.     }
  24.   }
  25.   return rv;
  26. }

代码示例来源：origin: naver/arcus-java-client

  1. private long mutateWithDefault(Mutator t, String key,
  2.                 int by, long def, int exp) {
  3.  long rv = mutate(t, key, by, def, exp);
  4.  // The ascii protocol doesn't support defaults, so I added them
  5.  // manually here.
  6.  if (rv == -1) {
  7.   Future<Boolean> f = asyncStore(StoreType.add,
  8.       key, exp, String.valueOf(def));
  9.   try {
  10.    if (f.get(operationTimeout, TimeUnit.MILLISECONDS)) {
  11.     rv = def;
  12.    } else {
  13.     rv = mutate(t, key, by, 0, exp);
  14.     assert rv != -1 : "Failed to mutate or init value";
  15.    }
  16.   } catch (InterruptedException e) {
  17.    throw new RuntimeException("Interrupted waiting for store", e);
  18.   } catch (ExecutionException e) {
  19.    throw new RuntimeException("Failed waiting for store", e);
  20.   } catch (TimeoutException e) {
  21.    throw new OperationTimeoutException(
  22.        "Timeout waiting to mutate or init value", e);
  23.   }
  24.  }
  25.  return rv;
  26. }

代码示例来源：origin: com.amazonaws/elasticache-java-cluster-client

  1. Future<Boolean> f = asyncStore(StoreType.add, key, exp,
  2.   String.valueOf(def));
  3. try {

内容来源于网络，如有侵权，请联系作者删除！

MemcachedClient

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    MemcachedClient类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com