EmSupplierTest.java 文件源码

@Test
public void asyncCleanLifeCycleTest() throws InterruptedException {
    EntityManagerFactory emf = mockEmf();
    final Coordinator coordinator = new DummyCoordinator();
    final EMSupplierImpl emSupplier = new EMSupplierImpl("myunit", emf,coordinator);
    final Semaphore preCallSem = new Semaphore(0);
    Runnable command = new Runnable() {

        @Override
        public void run() {
            coordinator.begin("test", 0);
            preCallSem.release();
            coordinator.pop().end();
        }
    };
    Executors.newSingleThreadExecutor().execute(command);
    preCallSem.acquire();
    // EMs not closed when close is called but are closed before timeout 
    boolean clean = emSupplier.close();
    Assert.assertTrue("Shutdown should be clean", clean);
}