Searched refs:concurrent (Results 1 – 25 of 111) sorted by relevance
12345
21 import java.util.concurrent.Callable;22 import java.util.concurrent.Executors;23 import java.util.concurrent.ExecutorService;24 import java.util.concurrent.Future;25 import java.util.concurrent.TimeUnit;26 import java.util.concurrent.CancellationException;27 import java.util.concurrent.TimeoutException;
153 void ReferenceProcessor::ProcessReferences(bool concurrent, in ProcessReferences() argument157 TimingLogger::ScopedTiming t(concurrent ? __FUNCTION__ : "(Paused)ProcessReferences", timings); in ProcessReferences()163 CHECK_EQ(SlowPathEnabled(), concurrent) << "Slow path must be enabled iff concurrent"; in ProcessReferences()166 CHECK_EQ(!self->GetWeakRefAccessEnabled(), concurrent); in ProcessReferences()179 TimingLogger::ScopedTiming split(concurrent ? "ForwardSoftReferences" : in ProcessReferences()181 if (concurrent) { in ProcessReferences()188 if (concurrent) { in ProcessReferences()196 TimingLogger::ScopedTiming t2(concurrent ? "EnqueueFinalizerReferences" : in ProcessReferences()198 if (concurrent) { in ProcessReferences()204 if (concurrent) { in ProcessReferences()[all …]
21 import java.util.concurrent.atomic.AtomicInteger;22 import java.util.concurrent.Callable;23 import java.util.concurrent.CyclicBarrier;24 import java.util.concurrent.ExecutionException;25 import java.util.concurrent.ExecutorService;26 import java.util.concurrent.Future;27 import java.util.concurrent.LinkedBlockingQueue;28 import java.util.concurrent.ThreadPoolExecutor;29 import java.util.concurrent.TimeUnit;
23 import concurrent.futures53 with concurrent.futures.ProcessPoolExecutor(args.jobs) as p:59 ws = concurrent.futures.wait(fs, return_when=concurrent.futures.FIRST_COMPLETED)
22 import java.util.concurrent.CountDownLatch;23 import java.util.concurrent.Semaphore;
19 import java.util.concurrent.atomic.AtomicInteger;20 import java.util.concurrent.CyclicBarrier;100 startBarrier.await(TIMEOUT_VALUE, java.util.concurrent.TimeUnit.MINUTES); in work()
22 import java.util.concurrent.CountDownLatch;24 import java.util.concurrent.atomic.*;
18 import java.util.concurrent.CountDownLatch;19 import static java.util.concurrent.TimeUnit.MINUTES;
23 import java.util.concurrent.CountDownLatch;25 import java.util.concurrent.atomic.*;
17 import java.util.concurrent.*;18 import java.util.concurrent.atomic.AtomicLong;
2 the concurrent gc.
19 import java.util.concurrent.CountDownLatch;
2 concurrent GC should locate the "hidden" objects through a write-barrier.
1 Regression test for the concurrent GC whose region space had
17 import java.util.concurrent.CountDownLatch;
19 import java.util.concurrent.locks.ReentrantLock;
17 import java.util.concurrent.Semaphore;
24 import java.util.concurrent.CyclicBarrier;25 import java.util.concurrent.atomic.AtomicInteger;
16 import java.util.concurrent.atomic.AtomicInteger;
17 import java.util.concurrent.atomic.AtomicInteger;
17 import java.util.concurrent.*;