HBASE-22634 Improve performance of BufferedMutator

Corrected unit test when neither hbase.htable.threads.max nor
hbase.client.max.total.tasks are set

Author: sbarnoud060710

hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutatorImpl.java

@@ -115,8 +115,11 @@ public class BufferedMutatorImpl implements BufferedMutator {
       cleanupPoolOnClose = false;
     }
     maxThreads = conf.getInt("hbase.htable.threads.max", Integer.MAX_VALUE);
-    if (maxThreads <= 0) {
+    if (maxThreads <= 0 || maxThreads == Integer.MAX_VALUE) {
       maxThreads = conf.getInt("hbase.client.max.total.tasks", Integer.MAX_VALUE);
+      if (maxThreads <= 0 || maxThreads == Integer.MAX_VALUE) {
+        maxThreads = 1;
+      }
     }
     asfList = new ArrayList<AsyncRequestFuture>(maxThreads*4);
     ConnectionConfiguration tableConf = new ConnectionConfiguration(conf);

hbase-client/src/main/java/org/apache/hadoop/hbase/client/BufferedMutatorThreadPoolExecutor.java

@@ -62,10 +62,10 @@ public BufferedMutatorThreadPoolExecutor(final int corePoolSize, final int maxim
 
   public static BufferedMutatorThreadPoolExecutor getPoolExecutor(Configuration conf) {
     int maxThreads = conf.getInt("hbase.htable.threads.max", Integer.MAX_VALUE);
-    if (maxThreads == 0) {
+    if (maxThreads <= 0 || maxThreads == Integer.MAX_VALUE) {
       maxThreads = conf.getInt("hbase.client.max.total.tasks", Integer.MAX_VALUE);
     }
-    if (maxThreads == 0) {
+    if (maxThreads <= 0 || maxThreads == Integer.MAX_VALUE) {
       throw new IllegalArgumentException("hbase.client.max.total.tasks must be >0");
     }
     long keepAliveTime = conf.getLong("hbase.htable.threads.keepalivetime", 60);