Searched refs:barrier1 (Results 1 – 1 of 1) sorted by relevance
341 final Semaphore barrier1 = new Semaphore(0); in testCancelableQuery_WhenCanceledDueToContention_StopsWaitingAndThrows() local347 barrier1.release(); // release query to start running in testCancelableQuery_WhenCanceledDueToContention_StopsWaitingAndThrows()373 barrier1.acquire(); // wait for contention thread to start transaction in testCancelableQuery_WhenCanceledDueToContention_StopsWaitingAndThrows()395 barrier1.release(); in testCancelableQuery_WhenCanceledDueToContention_StopsWaitingAndThrows()