Mailing-List: contact user-help@uima.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@uima.apache.org
MIME-Version: 1.0
From: nelson rivera <nelsonrivera12@gmail.com>
Date: Tue, 8 Nov 2016 10:00:08 -0500
Message-ID: <CAB3DYDq395rnJVDY0vv3e9V0VsWrgdNzPEUjrC0KDxnX1j3JDw@mail.gmail.com>
Subject: Free instance of agreggate with cas multiplier in MultiprocessingAnalysisEngine
To: user@uima.apache.org
Content-Type: text/plain; charset=UTF-8
archived-at: Tue, 08 Nov 2016 15:00:15 -0000

I have a aggregate analysis engine that contains a casmultiplier
annotator. I instantiate this aggregate with the interface
UIMAFramework.produceAnalysisEngine(specifier, 1, 0) for multithreaded
processing. The casmultiplier generate more than one cas for each
input CAS. The issue is that after first cas child, that i get with

 JCasIterator casIterator = analysisEngine.processAndOutputNewCASes(jcas);
while (casIterator.hasNext()) {
           JCas outCas = casIterator.next();
           ...
        outCas.release();
}

after this first cas child, the MultiprocessingAnalysisEngine_impl
assumes that the instance of
AggregateAnalysisEngine that processes the request has ended, Y
entonces esta instancia es libre para procesar otra solicitud de otro
hilo, and it is not true, because missing child cas, producing
concurrency errors.

What is the condition of a instance of MultiprocessingAnalysisEngine
that contains cas multiplier that generate many cas child for each
input Cas, for determine that it finish and is free?