From dev-return-194102-archive-asf-public=cust-asf.ponee.io@tomcat.apache.org Mon Oct 15 09:27:01 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id B7B18180647 for ; Mon, 15 Oct 2018 09:27:00 +0200 (CEST) Received: (qmail 49070 invoked by uid 500); 15 Oct 2018 07:26:59 -0000 Mailing-List: contact dev-help@tomcat.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: "Tomcat Developers List" Delivered-To: mailing list dev@tomcat.apache.org Received: (qmail 49057 invoked by uid 99); 15 Oct 2018 07:26:59 -0000 Received: from Unknown (HELO svn01-us-west.apache.org) (209.188.14.144) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Oct 2018 07:26:59 +0000 Received: from svn01-us-west.apache.org (localhost [127.0.0.1]) by svn01-us-west.apache.org (ASF Mail Server at svn01-us-west.apache.org) with ESMTP id 709383A009D for ; Mon, 15 Oct 2018 07:26:58 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1843880 - /tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java Date: Mon, 15 Oct 2018 07:26:58 -0000 To: dev@tomcat.apache.org From: kfujino@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20181015072658.709383A009D@svn01-us-west.apache.org> Author: kfujino Date: Mon Oct 15 07:26:58 2018 New Revision: 1843880 URL: http://svn.apache.org/viewvc?rev=1843880&view=rev Log: Use executor. The event notification of memberAdded or memberDisappeared does not prevent execution of the original thread. Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java?rev=1843880&r1=1843879&r2=1843880&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java (original) +++ tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java Mon Oct 15 07:26:58 2018 @@ -111,7 +111,19 @@ public abstract class CloudMembershipPro if (log.isDebugEnabled()) { log.debug("Member added: " + member); } - membershipListener.memberAdded(member); + Runnable r = new Runnable() { + @Override + public void run(){ + String name = Thread.currentThread().getName(); + try { + Thread.currentThread().setName("CloudMembership-memberAdded"); + membershipListener.memberAdded(member); + } finally { + Thread.currentThread().setName(name); + } + } + }; + executor.execute(r); } } // Remove non refreshed members from the membership @@ -120,7 +132,19 @@ public abstract class CloudMembershipPro if (log.isDebugEnabled()) { log.debug("Member disappeared: " + member); } - membershipListener.memberDisappeared(member); + Runnable r = new Runnable() { + @Override + public void run(){ + String name = Thread.currentThread().getName(); + try { + Thread.currentThread().setName("CloudMembership-memberDisappeared"); + membershipListener.memberDisappeared(member); + } finally { + Thread.currentThread().setName(name); + } + } + }; + executor.execute(r); } } --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org For additional commands, e-mail: dev-help@tomcat.apache.org