main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java
/**
     * Waits for the threads to shut down.
     *
     * @throws InterruptedException if interrupted while waiting
     */
Waits for the threads to shut down.
@throws InterruptedException if interrupted while waiting
Waits for the threads to shut down . @throws InterruptedException if interrupted while waiting
public void await() throws InterruptedException {
        toPapThread.join(WAIT_MS);
        assertFalse(toPapThread.isAlive());
        PdpModifyRequestMap map = Registry.get(PapConstants.REG_PDP_MODIFY_MAP);
        assertTrue(map.isEmpty());
        toPdps.add(DONE);
        toPdpsThread.join(WAIT_MS);
        assertFalse(toPapThread.isAlive());
        assertTrue(toPap.isEmpty());
        assertNull(exception);
    }
public void await ( ) throws InterruptedException { toPapThread . join ( WAIT_MS ) ; assertFalse ( toPapThread . isAlive ( ) ) ; PdpModifyRequestMap map = Registry . get ( PapConstants . REG_PDP_MODIFY_MAP ) ; assertTrue ( map . isEmpty ( ) ) ; toPdps . add ( DONE ) ; toPdpsThread . join ( WAIT_MS ) ; assertFalse ( toPapThread . isAlive ( ) ) ; assertTrue ( toPap . isEmpty ( ) ) ; assertNull ( exception ) ; }
Waits for the threads to shut down.
Waits for the threads to shut down .
// no more requests, thus we can tell the other thread to stop // nothing new should have been added to the PAP queue