Add TimeoutListener for MemcachedClient.

pom.xml

@@ -14,7 +14,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>net.spy</groupId>
     <artifactId>spymemcached</artifactId>
-    <version>2.999.999-SNAPSHOT</version> <!-- not used -->
+    <version>2.12.3-kwai-0.0.11</version> <!-- not used -->
 
     <name>Spymemcached</name>
     <description>A client library for memcached.</description>
@@ -42,6 +42,19 @@
             <organizationUrl>http://couchbase.com/</organizationUrl>
         </developer>
     </developers>
+    <!-- 发布位置配置 -->
+    <distributionManagement>
+        <repository>
+            <id>kuaishou.releases</id>
+            <name>Internal Release Repository</name>
+            <url>http://nexus.corp.kuaishou.com:88/nexus/content/repositories/releases/</url>
+        </repository>
+        <snapshotRepository>
+            <id>kuaishou.snapshots</id>
+            <name>Internal Snapshot Repository</name>
+            <url>http://nexus.corp.kuaishou.com:88/nexus/content/repositories/snapshots/</url>
+        </snapshotRepository>
+    </distributionManagement>
 
     <dependencies>
         <!-- Optional Dependencies at Runtime -->
@@ -85,5 +98,22 @@
         </dependency>
     </dependencies>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-source-plugin</artifactId>
+                <version>3.0.0</version>
+                <executions>
+                    <execution>
+                        <id>attach-sources</id>
+                        <goals>
+                            <goal>jar</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 
 </project>

src/main/java/net/spy/memcached/AsyncOpListener.java

@@ -0,0 +1,17 @@
+package net.spy.memcached;
+
+import net.spy.memcached.TimeoutListener.Method;
+import net.spy.memcached.internal.BulkGetFuture;
+import net.spy.memcached.internal.GetFuture;
+import net.spy.memcached.internal.OperationFuture;
+
+public interface AsyncOpListener<T> {
+
+  T beforeInvoke(Method method);
+
+  void onBulkGetCompletion(T before, BulkGetFuture<?> future);
+
+  void onGetCompletion(T before, GetFuture<?> future);
+
+  void onOperationCompletion(T before, Method method, OperationFuture<?> future);
+}

src/main/java/net/spy/memcached/ConnectionFactory.java

@@ -30,6 +30,7 @@
 import java.util.Collection;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
 
 import net.spy.memcached.auth.AuthDescriptor;
@@ -87,7 +88,7 @@ MemcachedNode createMemcachedNode(SocketAddress sa, SocketChannel c,
    * Get the ExecutorService which is used to asynchronously execute listeners
    * on futures.
    */
-  ExecutorService getListenerExecutorService();
+  Executor getListenerExecutorService();
 
   /**
    * Returns true if the default provided {@link ExecutorService} has not been

src/main/java/net/spy/memcached/ConnectionFactoryBuilder.java

@@ -27,6 +27,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
 
 import net.spy.memcached.auth.AuthDescriptor;
@@ -75,7 +76,7 @@ public class ConnectionFactoryBuilder {
 
   protected MetricType metricType = null;
   protected MetricCollector collector = null;
-  protected ExecutorService executorService = null;
+  protected Executor executor = null;
   protected long authWaitTime = DefaultConnectionFactory.DEFAULT_AUTH_WAIT_TIME;
 
   /**
@@ -311,8 +312,8 @@ public ConnectionFactoryBuilder setMetricCollector(MetricCollector collector) {
    *
    * @param executorService the ExecutorService to use.
    */
-  public ConnectionFactoryBuilder setListenerExecutorService(ExecutorService executorService) {
-    this.executorService = executorService;
+  public ConnectionFactoryBuilder setListenerExecutorService(Executor executorService) {
+    this.executor = executorService;
     return this;
   }
 
@@ -447,13 +448,13 @@ public MetricCollector getMetricCollector() {
       }
 
       @Override
-      public ExecutorService getListenerExecutorService() {
-        return executorService == null ? super.getListenerExecutorService() : executorService;
+      public Executor getListenerExecutorService() {
+        return executor == null ? super.getListenerExecutorService() : executor;
       }
 
       @Override
       public boolean isDefaultExecutorService() {
-        return executorService == null;
+        return executor == null;
       }
 
       @Override

src/main/java/net/spy/memcached/DefaultConnectionFactory.java

@@ -32,10 +32,9 @@
 import java.util.List;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.SynchronousQueue;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -132,9 +131,9 @@ public class DefaultConnectionFactory extends SpyObject implements
   private MetricCollector metrics;
 
   /**
-   * The ExecutorService in which the listener callbacks will be executed.
+   * The Executor in which the listener callbacks will be executed.
    */
-  private ExecutorService executorService;
+  private Executor executor;
 
   /**
    * Construct a DefaultConnectionFactory with the given parameters.
@@ -289,16 +288,16 @@ public long getAuthWaitTime() {
    * @return the stored {@link ExecutorService}.
    */
   @Override
-  public ExecutorService getListenerExecutorService() {
-    if (executorService == null) {
+  public Executor getListenerExecutorService() {
+    if (executor == null) {
       ThreadFactory threadFactory = new ThreadFactory() {
         @Override
         public Thread newThread(Runnable r) {
-          return new Thread(r, "FutureNotifyListener");
+          return new Thread(r, "FutureNotifyListener[" + DefaultConnectionFactory.this.getName() + "]");
         }
       };
 
-      executorService = new ThreadPoolExecutor(
+      executor = new ThreadPoolExecutor(
         0,
         Runtime.getRuntime().availableProcessors(),
         60L,
@@ -308,7 +307,7 @@ public Thread newThread(Runnable r) {
       );
     }
 
-    return executorService;
+    return executor;
   }
 
   @Override