@Override
        public void onComplete(Future future) throws Exception {
          latch.countDown();
        }
Use an unbounded thread pool for testing, which is very similar to
the one used in the {@link DefaultConnectionFactory}.
src/test/java/net/spy/memcached/internal/ListenableFutureTest.java