From: Roger Meier <roger@apache.org>
Date: Thu, 29 May 2014 14:25:22 +0000 (+0200)
Subject: THRIFT-2551 OutOfMemoryError "unable to create new native thread" kills serve thread
X-Git-Url: https://source.supwisdom.com/gerrit/gitweb?a=commitdiff_plain;h=80a44f84fb161d77bf53261d024489df0aa7589c;p=common%2Fthrift.git

THRIFT-2551 OutOfMemoryError "unable to create new native thread" kills serve thread

Github Pull Request: This closes #112

Patch: Fuud
---

diff --git a/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java b/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java
old mode 100644
new mode 100755
index 7229d898..488d17fb
--- a/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java
+++ b/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java
@@ -139,6 +139,16 @@ public class TThreadPoolServer extends TServer {
               Thread.currentThread().interrupt();
               break;
             }
+          } catch(OutOfMemoryError ex) {
+            LOGGER.warn("ExecutorService throws OutOfMemoryError "+ ex.getMessage() + (++rejections) +
+                " times(s)", ex);
+            try {
+              TimeUnit.SECONDS.sleep(1);
+            } catch (InterruptedException e) {
+              LOGGER.warn("Interrupted while waiting to place client on executor queue.");
+              Thread.currentThread().interrupt();
+              break;
+            }
           }
         }
       } catch (TTransportException ttx) {