Return-Path: X-Original-To: apmail-zookeeper-user-archive@www.apache.org Delivered-To: apmail-zookeeper-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 852339EEE for ; Tue, 6 Mar 2012 05:07:45 +0000 (UTC) Received: (qmail 14327 invoked by uid 500); 6 Mar 2012 05:07:45 -0000 Delivered-To: apmail-zookeeper-user-archive@zookeeper.apache.org Received: (qmail 14222 invoked by uid 500); 6 Mar 2012 05:07:43 -0000 Mailing-List: contact user-help@zookeeper.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@zookeeper.apache.org Delivered-To: mailing list user@zookeeper.apache.org Received: (qmail 14175 invoked by uid 99); 6 Mar 2012 05:07:41 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 06 Mar 2012 05:07:41 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of amirhkiani@gmail.com designates 209.85.160.42 as permitted sender) Received: from [209.85.160.42] (HELO mail-pw0-f42.google.com) (209.85.160.42) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 06 Mar 2012 05:07:33 +0000 Received: by pbcun1 with SMTP id un1so4053494pbc.15 for ; Mon, 05 Mar 2012 21:07:12 -0800 (PST) Received-SPF: pass (google.com: domain of amirhkiani@gmail.com designates 10.68.196.162 as permitted sender) client-ip=10.68.196.162; Authentication-Results: mr.google.com; spf=pass (google.com: domain of amirhkiani@gmail.com designates 10.68.196.162 as permitted sender) smtp.mail=amirhkiani@gmail.com; dkim=pass header.i=amirhkiani@gmail.com Received: from mr.google.com ([10.68.196.162]) by 10.68.196.162 with SMTP id in2mr3551413pbc.17.1331010432935 (num_hops = 1); Mon, 05 Mar 2012 21:07:12 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=content-type:mime-version:subject:from:in-reply-to:date :content-transfer-encoding:message-id:references:to:x-mailer; bh=HgMsOR96azPU6rJSJFhnmbvSu8rBVccd1poqFz6xtsQ=; b=bCwJ+KkBpy0f7ea/GIALcNEoMW+27av8hpX+LSbkJmRpaOb1Ik7SGeAjc3bPIUwIyN IzmwDZXt8qSgGdrABAqSecdiT0L2FZfaustyW28ykPkLw6g+YLx0nuXFLirBbCipkQI/ 6kBxGY4xqT50L//Sp+Gwv7VAuScorSOeS00RM/cNMwo0IJOEgbwQGrIwQ+PDmaMNkIqa 0yy3h8xoObT83Lqux+nTsl6U9qYTKrYs6kMe0t8rAymD+kvfWY22+DGaxpHDBFMVAZru LCghqNNjMb83jcfvgudNNHgn4Gv9/dlxe8085QTiHL3Xb6Xwv5kHaOAVKbljsX+Afu1f Oefw== Received: by 10.68.196.162 with SMTP id in2mr2953008pbc.17.1331010432891; Mon, 05 Mar 2012 21:07:12 -0800 (PST) Received: from amiroo.localnet (50-78-98-94-static.hfc.comcastbusiness.net. [50.78.98.94]) by mx.google.com with ESMTPS id f6sm15240667pbq.64.2012.03.05.21.07.11 (version=TLSv1/SSLv3 cipher=OTHER); Mon, 05 Mar 2012 21:07:11 -0800 (PST) Content-Type: text/plain; charset=us-ascii Mime-Version: 1.0 (Apple Message framework v1251.1) Subject: Re: Are curator framework consumers single threaded? From: Amirhossein Kiani In-Reply-To: <08BF7E6B-DCC9-48C8-BDCF-097D8A56C496@gmail.com> Date: Mon, 5 Mar 2012 21:07:09 -0800 Content-Transfer-Encoding: quoted-printable Message-Id: <9B7BB628-498A-4715-87BF-CF84619495F9@gmail.com> References: <08BF7E6B-DCC9-48C8-BDCF-097D8A56C496@gmail.com> To: Jordan Zimmerman , user@zookeeper.apache.org X-Mailer: Apple Mail (2.1251.1) X-Virus-Checked: Checked by ClamAV on apache.org + Jordan (My apologies if this is not the right mailing list... I looked = around and couldn't find a mailing list for Curator) I was also wondering if there are examples on how to use Curator. I have = been following the tests and I'm worried that I'm doing something = wrong... Many thanks, Amir On Mar 5, 2012, at 8:18 PM, Amirhossein Kiani wrote: > Hi Jordan, >=20 > First of all, thanks a lot for all the great work on Curator! I have = started using it and it is amazingly simplifying my code! >=20 > I have just ran into this issue recently that I am using a Distributed = Queue, a Path Cache and a Distributed Double Barrier in my code, and = having some difficulties. I'm trying to run everything with the test = framework Curator provides and it seems like when I enter() the barrier = in one of my objects the other one (that is using a different client) is = also blocked. > Is there a way to have the Queue consumer object as well as Event = listeners for the Path Cache start in new threads? >=20 > Many thanks, > Amir