Searched refs:concurrent (Results 1 – 25 of 2440) sorted by relevance
12345678910>>...98
18 do 10 concurrent (i = 1:n)39 do concurrent (i = 1:n)57 do concurrent (i = 1:n)65 do concurrent (i = 1:n)74 do concurrent (i = 1:n)84 do concurrent (i = 1:n)94 do concurrent (i = 1:n)103 do concurrent (i = 1:n)132 do concurrent (i = 1:10)136 do concurrent (i = 1:10)[all …]
11 do concurrent (i=1:10) local(i)17 do concurrent (i=1:10) local_init(i)23 do concurrent (j=i:10) local(i)29 do concurrent (j=i:10) local_init(i)35 do concurrent (j=i:10) shared(i)41 do concurrent (j=1:i) local(i)47 do concurrent (j=1:i) local_init(i)53 do concurrent (j=1:i) shared(i)59 do concurrent (j=1:10:i) local(i)65 do concurrent (j=1:10:i) local_init(i)[all …]
11 do concurrent (i=1:5) local(arg)21 do concurrent (i=1:5) local(arg)33 do concurrent (i=1:5) local(prot)43 do concurrent (i=1:5) local(prot)47 do concurrent (i=1:5) local(var)57 do concurrent (i=1:5) local(d)62 do concurrent (i=1:5) local(a)83 do concurrent (i=1:5) local(a)91 do concurrent (i=1:5) local(a)112 do concurrent (i=1:5) local(var)[all …]
42 do concurrent (ivar = 1:10)66 do concurrent (ivar = 1:10)96 do concurrent (ivar = 1:10)119 do concurrent (ivar = 1:10)141 do concurrent (ivar = 1:10)166 do concurrent (ivar = 1:10)191 do concurrent (iostatVar = 1:10)207 do concurrent (nextrecVar = 1:10)223 do concurrent (numberVar = 1:10)239 do concurrent (reclVar = 1:10)[all …]
12 do concurrent(i=1:5) local(k)20 do concurrent(i=1:5) local(arg)27 do concurrent(i=1:5) local(arg)35 do concurrent(i=1:5) local(arg)50 do concurrent(i=1:5) local(var)69 do concurrent(i=1:5) local(x)74 do concurrent(i=1:5) local(y)83 do concurrent(i=1:5) local(coarray_var)91 do concurrent(i=1:5) local(arg)
9 nc1: do concurrent(i1=1:n)11 nc3: do concurrent(i3=1:n)13 nc5: do concurrent(i5=1:n)32 nc1: do concurrent(i1=1:n)34 nc3: do concurrent(i3=1:n)36 nc5: do concurrent(i5=1:n)54 nc1: do concurrent(i1=1:n)56 nc3: do concurrent(i3=1:n)60 nc5: do concurrent(i5=1:n)
15 package com.google.common.util.concurrent;17 import static com.google.common.util.concurrent.Futures.getUnchecked;18 import static com.google.common.util.concurrent.Futures.immediateFuture;19 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION;20 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;21 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR_FUTURE;22 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_CHECKED_EXCEP…23 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_ERROR;24 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_OTHER_THROWAB…25 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_UNCHECKED_EXC…[all …]
15 package com.google.common.util.concurrent;18 import static com.google.common.util.concurrent.ClassPathUtil.parseJavaClassPath;19 import static com.google.common.util.concurrent.Futures.getChecked;20 import static com.google.common.util.concurrent.Futures.immediateFuture;21 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION;22 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;23 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR_FUTURE;24 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_CHECKED_EXCEP…25 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_ERROR;26 import static com.google.common.util.concurrent.FuturesGetCheckedInputs.FAILED_FUTURE_OTHER_THROWAB…[all …]
17 package com.google.common.util.concurrent;21 import static com.google.common.util.concurrent.FuturesTest.failureWithCause;22 import static com.google.common.util.concurrent.FuturesTest.pseudoTimedGetUninterruptibly;23 import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;24 import static java.util.concurrent.TimeUnit.MILLISECONDS;25 import static java.util.concurrent.TimeUnit.SECONDS;30 import java.util.concurrent.ExecutionException;31 import java.util.concurrent.Future;32 import java.util.concurrent.TimeoutException;
17 package com.google.common.util.concurrent;20 import static com.google.common.util.concurrent.Callables.returning;21 import static com.google.common.util.concurrent.Futures.getDone;22 import static com.google.common.util.concurrent.TestPlatform.verifyThreadWasNotInterrupted;26 import java.util.concurrent.Callable;27 import java.util.concurrent.CancellationException;28 import java.util.concurrent.CountDownLatch;29 import java.util.concurrent.CyclicBarrier;30 import java.util.concurrent.ExecutionException;31 import java.util.concurrent.ExecutorService;[all …]
17 package com.google.common.util.concurrent;19 import static com.google.common.util.concurrent.InterruptionUtil.repeatedlyInterruptTestThread;20 import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;21 import static java.util.concurrent.TimeUnit.MINUTES;22 import static java.util.concurrent.TimeUnit.SECONDS;26 import java.util.concurrent.Callable;27 import java.util.concurrent.ExecutionException;28 import java.util.concurrent.ExecutorService;29 import java.util.concurrent.Executors;30 import java.util.concurrent.Future;[all …]
2 …public static final fun awaitFirst (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Contin…3 …public static final fun awaitFirstOrDefault (Ljava/util/concurrent/Flow$Publisher;Ljava/lang/Objec…4 …public static final fun awaitFirstOrElse (Ljava/util/concurrent/Flow$Publisher;Lkotlin/jvm/functio…5 …public static final fun awaitFirstOrNull (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/…6 …public static final fun awaitLast (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continu…7 …public static final fun awaitSingle (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Conti…11 …/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Ljava/util/concurrent/Flow$Publisher;12 …neContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Ljava/util/concurrent/Flow$Publisher;16 …public static final fun asFlow (Ljava/util/concurrent/Flow$Publisher;)Lkotlinx/coroutines/flow/Flo…17 …public static final fun asPublisher (Lkotlinx/coroutines/flow/Flow;)Ljava/util/concurrent/Flow$Pub…[all …]
17 package com.google.common.util.concurrent.testing;19 import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;23 import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFutur…24 import com.google.common.util.concurrent.ListenableFuture;25 import com.google.common.util.concurrent.ListenableScheduledFuture;26 import com.google.common.util.concurrent.ListeningExecutorService;27 import com.google.common.util.concurrent.ListeningScheduledExecutorService;30 import java.util.concurrent.AbstractExecutorService;31 import java.util.concurrent.Callable;32 import java.util.concurrent.Delayed;[all …]
17 package com.google.common.util.concurrent.testing;23 import com.google.common.util.concurrent.AbstractFuture;24 import com.google.common.util.concurrent.AbstractListeningExecutorService;25 import com.google.common.util.concurrent.ListenableScheduledFuture;26 import com.google.common.util.concurrent.ListeningScheduledExecutorService;27 import com.google.common.util.concurrent.MoreExecutors;29 import java.util.concurrent.Callable;30 import java.util.concurrent.Delayed;31 import java.util.concurrent.ScheduledFuture;32 import java.util.concurrent.TimeUnit;
17 package com.google.common.util.concurrent;21 import static com.google.common.util.concurrent.Futures.immediateFailedFuture;22 import static com.google.common.util.concurrent.Futures.immediateFuture;23 import static com.google.common.util.concurrent.FuturesGetChecked.checkExceptionClassValidity;24 import static com.google.common.util.concurrent.FuturesGetChecked.classValueValidator;25 import static com.google.common.util.concurrent.FuturesGetChecked.getChecked;26 import static com.google.common.util.concurrent.FuturesGetChecked.isCheckedException;27 import static com.google.common.util.concurrent.FuturesGetChecked.weakSetValidator;33 import com.google.common.util.concurrent.FuturesGetChecked.GetCheckedTypeValidator;40 import java.util.concurrent.BrokenBarrierException;[all …]
15 package com.google.common.util.concurrent;18 import static java.util.concurrent.TimeUnit.NANOSECONDS;22 import java.util.concurrent.Callable;23 import java.util.concurrent.ExecutionException;24 import java.util.concurrent.Executor;25 import java.util.concurrent.FutureTask;26 import java.util.concurrent.TimeUnit;27 import java.util.concurrent.TimeoutException;