/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/sample/chatserver/ |
H A D | ChatTest.java | 148 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performDontReceiveMessageInNameState() local 160 barrier1.await(); in performDontReceiveMessageInNameState() 170 barrier1.await(); in performDontReceiveMessageInNameState() 197 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestUsernameAndMessage() local 209 barrier1.await(); in performTestUsernameAndMessage() 222 barrier1.await(); in performTestUsernameAndMessage() 237 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestConnectDisconnectConnect() local 257 barrier1.await(); in performTestConnectDisconnectConnect() 272 barrier1.await(); in performTestConnectDisconnectConnect() 304 barrier1.await(); in performTestUseName() [all …]
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/sample/chatserver/ |
H A D | ChatTest.java | 148 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performDontReceiveMessageInNameState() local 160 barrier1.await(); in performDontReceiveMessageInNameState() 170 barrier1.await(); in performDontReceiveMessageInNameState() 197 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestUsernameAndMessage() local 209 barrier1.await(); in performTestUsernameAndMessage() 222 barrier1.await(); in performTestUsernameAndMessage() 237 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestConnectDisconnectConnect() local 257 barrier1.await(); in performTestConnectDisconnectConnect() 272 barrier1.await(); in performTestConnectDisconnectConnect() 304 barrier1.await(); in performTestUseName() [all …]
|
/dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/quorum/include/jflib/ |
H A D | locks_pthread.hpp | 148 Semaphore barrier1; // implement the barrier member in jflib::locks::pthread::barrier 153 : count(cnt), current(0), barrier1(0), barrier2(0) { in barrier() 165 barrier1.signal(); in wait() 169 barrier1.wait(); // wait for n threads to arrive in wait()
|
/dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/jellyfish/include/jellyfish/ |
H A D | locks_pthread.hpp | 167 Semaphore barrier1; // implement the barrier member in jellyfish::locks::pthread::barrier 172 : count(cnt), current(0), barrier1(0), barrier2(0) { in barrier() 184 barrier1.signal(); in wait() 188 barrier1.wait(); // wait for n threads to arrive in wait()
|
/dports/biology/jellyfish/jellyfish-2.3.0/include/jellyfish/ |
H A D | locks_pthread.hpp | 159 Semaphore barrier1; // implement the barrier member in jellyfish::locks::pthread::barrier 164 : count(cnt), current(0), barrier1(0), barrier2(0) { in barrier() 176 barrier1.signal(); in wait() 180 barrier1.wait(); // wait for n threads to arrive in wait()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
H A D | ActionBlockTests.cs | 206 Barrier barrier1 = new Barrier(2), barrier2 = new Barrier(2); in TestInputCount() 209 barrier1.SignalAndWait(); in TestInputCount() 223 barrier1.SignalAndWait(); in TestInputCount() 262 var barrier1 = new Barrier(2); in TestNonGreedy() 263 Action<int> body = _ => barrier1.SignalAndWait(); in TestNonGreedy() 278 barrier1.SignalAndWait(); in TestNonGreedy() 445 Barrier barrier1 = new Barrier(2), barrier2 = new Barrier(2); in TestReleasingOfPostponedMessages() 446 Action<int> body = i => { barrier1.SignalAndWait(); barrier2.SignalAndWait(); }; in TestReleasingOfPostponedMessages() 453 barrier1.SignalAndWait(); in TestReleasingOfPostponedMessages()
|
H A D | TransformBlockTests.cs | 291 Barrier barrier1 = new Barrier(2), barrier2 = new Barrier(2); in TestInputCount() 293 barrier1.SignalAndWait(); in TestInputCount() 308 barrier1.SignalAndWait(); in TestInputCount()
|
/dports/sysutils/diskonaut/diskonaut-0.11.0/cargo-crates/mio-0.7.0/tests/ |
H A D | poll.rs | 237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable 259 barrier1.wait(); in registry_operations_are_thread_safe() 260 barrier1.wait(); in registry_operations_are_thread_safe() 319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable 324 barrier1.wait(); in register_during_poll() 333 barrier1.wait(); in register_during_poll() 424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable 444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops() 450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
|
/dports/graphics/viu/viu-1.1/cargo-crates/mio-0.7.0/tests/ |
H A D | poll.rs | 237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable 259 barrier1.wait(); in registry_operations_are_thread_safe() 260 barrier1.wait(); in registry_operations_are_thread_safe() 319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable 324 barrier1.wait(); in register_during_poll() 333 barrier1.wait(); in register_during_poll() 424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable 444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops() 450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
|
/dports/devel/gitui/gitui-0.10.1/cargo-crates/mio-0.7.0/tests/ |
H A D | poll.rs | 237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable 259 barrier1.wait(); in registry_operations_are_thread_safe() 260 barrier1.wait(); in registry_operations_are_thread_safe() 319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable 324 barrier1.wait(); in register_during_poll() 333 barrier1.wait(); in register_during_poll() 424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable 444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops() 450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
|
/dports/devel/desed/desed-1.2.0/cargo-crates/mio-0.7.0/tests/ |
H A D | poll.rs | 237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable 259 barrier1.wait(); in registry_operations_are_thread_safe() 260 barrier1.wait(); in registry_operations_are_thread_safe() 319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable 324 barrier1.wait(); in register_during_poll() 333 barrier1.wait(); in register_during_poll() 424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable 444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops() 450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
|
/dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/mio-0.7.0/tests/ |
H A D | poll.rs | 237 let barrier1 = Arc::clone(&barrier); 259 barrier1.wait(); 260 barrier1.wait(); 319 let barrier1 = Arc::clone(&barrier); 324 barrier1.wait(); 333 barrier1.wait(); 424 let barrier1 = Arc::clone(&barrier); 444 barrier1.wait(); 450 barrier1.wait();
|
/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.runtime/tests/org.eclipse.core.tests.runtime/src/org/eclipse/core/tests/runtime/jobs/ |
H A D | YieldTest.java | 99 final TestBarrier barrier1 = new TestBarrier(location, 0); in testExceptionWhenYieldingNotOwner() local 106 barrier1.waitForStatus(TestBarrier.STATUS_START); in testExceptionWhenYieldingNotOwner() 120 barrier1.setStatus(TestBarrier.STATUS_START); in testExceptionWhenYieldingNotOwner() 282 final TestBarrier barrier1 = new TestBarrier(location, 0); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume() local 287 barrier1.waitForStatus(TestBarrier.STATUS_START); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume() 288 barrier1.setStatus(TestBarrier.STATUS_RUNNING); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume() 292 barrier1.waitForStatus(TestBarrier.STATUS_DONE); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume() 302 barrier1.setStatus(TestBarrier.STATUS_DONE); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume() 317 barrier1.setStatus(TestBarrier.STATUS_START); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume()
|
/dports/misc/visp/visp-3.4.0/3rdparty/pthreads4w/ |
H A D | Nmakefile.tests | 124 barrier1:: barrier1.c 244 barrier1 :test: 245 barrier2 :test: barrier1.c
|
/dports/devel/mingw32-pthreads/pthreads-w32-2-8-0-release/ |
H A D | Nmakefile.tests | 124 barrier1:: barrier1.c 244 barrier1 :test: 245 barrier2 :test: barrier1.c
|
/dports/multimedia/obs-studio/obs-studio-27.1.3/deps/w32-pthreads/ |
H A D | Nmakefile.tests | 124 barrier1:: barrier1.c 244 barrier1 :test: 245 barrier2 :test: barrier1.c
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/metrics2/impl/ |
H A D | TestMetricsSystemImpl.java | 108 final CyclicBarrier barrier1 = new CyclicBarrier(numThreads), in testMultiThreadedPublish() local 117 barrier1.await(2, TimeUnit.SECONDS); in testMultiThreadedPublish() 145 if (!safeAwait(mySource, barrier1)) return; in testMultiThreadedPublish()
|
/dports/finance/quantlib/QuantLib-1.20/test-suite/ |
H A D | doublebarrieroption.cpp | 73 barrier1, barrier2, rebate, payoff, \ argument 84 << " barrier1: " << barrier1 << "\n" \ 127 Real barrier1; member 494 values[i].barrier1, in testVannaVolgaDoubleBarrierValues() 528 values[i].barrier1, values[i].barrier2, in testVannaVolgaDoubleBarrierValues() 553 values[i].barrier1, values[i].barrier2, in testVannaVolgaDoubleBarrierValues()
|
/dports/multimedia/obs-studio/obs-studio-27.1.3/deps/w32-pthreads/tests/ |
H A D | GNUmakefile | 111 barrier1 barrier2 barrier3 barrier4 barrier5 barrier6 \ 150 barrier1 barrier2 barrier3 barrier4 barrier5 barrier6 \ 250 barrier1.pass: semaphore4.pass 251 barrier2.pass: barrier1.pass
|
H A D | Makefile | 107 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass barrier6.pass \ 153 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass barrier6.pass \ 317 barrier1.pass: semaphore4.pass 318 barrier2.pass: barrier1.pass
|
H A D | Wmakefile | 117 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass & 226 barrier1.pass: 227 barrier2.pass: barrier1.pass
|
/dports/devel/mingw32-pthreads/pthreads-w32-2-8-0-release/tests/ |
H A D | GNUmakefile | 93 barrier1 barrier2 barrier3 barrier4 barrier5 \ 188 barrier1.pass: semaphore4.pass 189 barrier2.pass: barrier1.pass
|
H A D | Makefile | 103 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass \ 278 barrier1.pass: semaphore4.pass 279 barrier2.pass: barrier1.pass
|
H A D | Wmakefile | 113 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass & 222 barrier1.pass: 223 barrier2.pass: barrier1.pass
|
H A D | Bmakefile | 99 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass \ 224 barrier1.pass: semaphore4.pass 225 barrier2.pass: barrier1.pass
|