Method trainC

JSAT/src/jsat/classifiers/boosting/Bagging.java:208–272

(final ClassificationDataSet dataSet, final ExecutorService threadPool)

    }

    @Override
    public void trainC(final ClassificationDataSet dataSet, final ExecutorService threadPool)
    {
        predicting = dataSet.getPredicting();
        learners = new ArrayList(rounds);
        //Used to make the main thread wait for the working threads to finish before submiting a new job so we dont waist too much memory then we can use at once
        final Semaphore waitForThread = new Semaphore(SystemInfo.LogicalCores);
        //Used to make the main thread wait for the working threads to finish before returning 
        final CountDownLatch waitForFinish = new CountDownLatch(rounds);
        
        //Creat a synchrnozied view so we can add safely 
        final List synchronizedLearners = Collections.synchronizedList(learners);
        final int[] sampleCounts = new int[dataSet.getSampleSize()];
        for(int i = 0; i < rounds; i++)
        {
            sampleWithReplacement(sampleCounts, sampleCounts.length+extraSamples, random);
            final ClassificationDataSet sampleSet = getSampledDataSet(dataSet, sampleCounts);
            
            final Classifier learner = baseClassifier.clone();
            if(simultaniousTraining && threadPool != null)
            {
                try
                {
                    //Wait for an available thread
                    waitForThread.acquire();
                    threadPool.submit(new Runnable() {

                        @Override
                        public void run()
                        {
                            learner.trainC(sampleSet);
                            synchronizedLearners.add(learner);
                            waitForThread.release();//Finish, allow another one to pass through
                            waitForFinish.countDown();
                        }
                    });
                }
                catch (InterruptedException ex)
                {
                    Logger.getLogger(Bagging.class.getName()).log(Level.SEVERE, null, ex);
                    System.err.println(ex.getMessage());
                }
                
            }
            else
            {
                if(threadPool != null)
                    learner.trainC(sampleSet, threadPool);
                else
                    learner.trainC(sampleSet);
                learners.add(learner);
            }
        }

        if (simultaniousTraining && threadPool != null)
            try
            {
                waitForFinish.await();