From 504598b320c689cca3d1bbf523a4dd82f69d7a61 Mon Sep 17 00:00:00 2001 From: Fabian Mastenbroek Date: Thu, 28 Sep 2017 16:56:25 +0200 Subject: Add thread pool for experiment platform --- .../nl/atlarge/opendc/platform/JpaExperimentManager.kt | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) (limited to 'opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperimentManager.kt') diff --git a/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperimentManager.kt b/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperimentManager.kt index faa1a771..ce69f84b 100644 --- a/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperimentManager.kt +++ b/opendc-integration-jpa/src/main/kotlin/nl/atlarge/opendc/platform/JpaExperimentManager.kt @@ -27,14 +27,21 @@ package nl.atlarge.opendc.platform import nl.atlarge.opendc.integration.jpa.schema.Experiment as InternalExperiment import nl.atlarge.opendc.integration.jpa.schema.ExperimentState import javax.persistence.EntityManager +import javax.persistence.EntityManagerFactory /** * A manager for [Experiment]s received from a JPA database. * - * @property manager The JPA entity manager to retrieve entities from the database from. + * @property factory The JPA entity manager factory to create [EntityManager]s to retrieve entities from the database + * from. * @author Fabian Mastenbroek (f.s.mastenbroek@student.tudelft.nl) */ -class JpaExperimentManager(private val manager: EntityManager) { +class JpaExperimentManager(private val factory: EntityManagerFactory) { + /** + * The entity manager for this experiment. + */ + private val manager: EntityManager = factory.createEntityManager() + /** * The amount of experiments in the queue. This property makes a call to the database and does therefore not * run in O(1) time. @@ -68,6 +75,6 @@ class JpaExperimentManager(private val manager: EntityManager) { experiment!!.state = ExperimentState.CLAIMED } manager.transaction.commit() - return experiment?.let { JpaExperiment(manager, it) } + return experiment?.let { JpaExperiment(factory.createEntityManager(), it) } } } -- cgit v1.2.3