D-Net

 * @author Nikon Gasparis

 *

 */

public class ThreadExecutorSubmitter extends ExecutorSubmitter {

	private transient Logger log = Logger.getLogger(ThreadExecutorSubmitter.class);

 * @author Nikon Gasparis

 * @see ExecutorService

 */

public class MemoryThreadValidator implements Validator {

	private CacheManager cacheManager;

		CrisListener crisListener = listenersManager.createCrisListener();

		crisListener.setWorkersFirstPhase(rulesPerEntity.keySet().size());

		crisListener.setProvider(prv);

		crisListener.setWorkers(rulesPerEntity.keySet().size() + rulesPerEntityRef.keySet().size());

		if (!rulesPerEntityRef.isEmpty()) {

			prv.setConfiguration(props);

			submittersForReferential.add(new ThreadExecutorSubmitter(job.id, entry.getValue(), entry.getKey(), prv, mainListener, taskExecutor, timeout, generalTimeout, listeners));

		}

		log.error("Sumbitters created for referential check: " + submittersForReferential.size());

	}

	/**

	 * Creates a new validator.

	 * 

	 *            The module used to run the providers and submit jobs.

	 * @param taskExecutor

	 *            The executor used to execute the jobs.

	 * @param generalTimeout

	 *            How long to wait for a job to be executed (in seconds). A job

	 *            is composed of the application of all the rules on all of the

		//TODO UPDATE LISTENER

		//		crisListener.setExecutor(taskExecutor);

		crisListener.setProvider(prv);

		crisListener.setWorkers(rulesPerEntity.keySet().size()

		}

		//TODO UPDATE LISTENER

//		crisListener.setSubmittersForReferential(submittersForReferential);

		log.error("Sumbitters created for referential check: "

				+ submittersForReferential.size());

import java.util.Map;

import java.util.concurrent.ExecutorService;

import net.sf.ehcache.CacheManager;

import org.apache.log4j.Logger;

import org.springframework.stereotype.Controller;

import eu.dnetlib.validator.engine.execution.CompletedTask;

	private int workersFirstPhase = 0;

	private int workersFinished = 0;

	private int workers;

	private CrisProvider provider;

	private CacheManager cacheManager = null;

	private String cacheName = null;

	public void beginCrisReferentialCheck() {

		provider.restartResultSets();

		}

	}

	@Override

		this.workers = workers;

	}

		this.executor = executor;

	}

		this.submittersForReferential = submittersForReferential;

	}