From 80a44f84fb161d77bf53261d024489df0aa7589c Mon Sep 17 00:00:00 2001
From: Roger Meier <roger@apache.org>
Date: Thu, 29 May 2014 16:25:22 +0200
Subject: [PATCH] THRIFT-2551 OutOfMemoryError "unable to create new native
 thread" kills serve thread

Github Pull Request: This closes #112

Patch: Fuud
---
 .../org/apache/thrift/server/TThreadPoolServer.java    | 10 ++++++++++
 1 file changed, 10 insertions(+)
 mode change 100644 => 100755 lib/java/src/org/apache/thrift/server/TThreadPoolServer.java

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) {
-- 
2.17.1