Home
last modified time | relevance | path

Searched refs:U (Results 1 – 25 of 91) sorted by relevance

1234

/libcore/ojluni/src/main/java/java/util/concurrent/
DCompletionStage.java170 public <U> CompletionStage<U> thenApply(Function<? super T,? extends U> fn); in thenApply()
186 public <U> CompletionStage<U> thenApplyAsync in thenApplyAsync()
187 (Function<? super T,? extends U> fn); in thenApplyAsync()
203 public <U> CompletionStage<U> thenApplyAsync in thenApplyAsync()
204 (Function<? super T,? extends U> fn, in thenApplyAsync()
308 public <U,V> CompletionStage<V> thenCombine in thenCombine()
309 (CompletionStage<? extends U> other, in thenCombine()
310 BiFunction<? super T,? super U,? extends V> fn); in thenCombine() argument
328 public <U,V> CompletionStage<V> thenCombineAsync in thenCombineAsync()
329 (CompletionStage<? extends U> other, in thenCombineAsync()
[all …]
DExchanger.java364 Node q = (Node)U.getObjectVolatile(a, j = (i << ASHIFT) + ABASE); in arenaExchange()
365 if (q != null && U.compareAndSwapObject(a, j, q, null)) { in arenaExchange()
370 U.unpark(w); in arenaExchange()
375 if (U.compareAndSwapObject(a, j, null, p)) { in arenaExchange()
381 U.putOrderedObject(p, MATCH, null); in arenaExchange()
394 else if (U.getObjectVolatile(a, j) != p) in arenaExchange()
399 U.putObject(t, BLOCKER, this); // emulate LockSupport in arenaExchange()
401 if (U.getObjectVolatile(a, j) == p) in arenaExchange()
402 U.park(false, ns); in arenaExchange()
404 U.putObject(t, BLOCKER, null); in arenaExchange()
[all …]
DCompletableFuture.java226 return U.compareAndSwapObject(this, RESULT, null, r); in internalComplete()
230 return U.compareAndSwapObject(this, STACK, cmp, val); in casStack()
237 return U.compareAndSwapObject(this, STACK, h, c); in tryPushStack()
257 return U.compareAndSwapObject(this, RESULT, null, in completeNull()
268 return U.compareAndSwapObject(this, RESULT, null, in completeValue()
283 return U.compareAndSwapObject(this, RESULT, null, in completeThrowable()
311 return U.compareAndSwapObject(this, RESULT, null, in completeThrowable()
341 return U.compareAndSwapObject(this, RESULT, null, in completeRelay()
459 U.putOrderedObject(c, NEXT, next); in lazySetNext()
1042 abstract static class BiCompletion<T,U,V> extends UniCompletion<T,V> {
[all …]
DFutureTask.java167 U.compareAndSwapInt(this, STATE, NEW, in cancel()
177 U.putOrderedInt(this, STATE, INTERRUPTED); in cancel()
231 if (U.compareAndSwapInt(this, STATE, NEW, COMPLETING)) { in set()
233 U.putOrderedInt(this, STATE, NORMAL); // final state in set()
249 if (U.compareAndSwapInt(this, STATE, NEW, COMPLETING)) { in setException()
251 U.putOrderedInt(this, STATE, EXCEPTIONAL); // final state in setException()
258 !U.compareAndSwapObject(this, RUNNER, null, Thread.currentThread())) in run()
299 !U.compareAndSwapObject(this, RUNNER, null, Thread.currentThread())) in runAndReset()
366 if (U.compareAndSwapObject(this, WAITERS, q, null)) { in finishCompletion()
428 queued = U.compareAndSwapObject(this, WAITERS, in awaitDone()
[all …]
DConcurrentHashMap.java763 return (Node<K,V>)U.getObjectVolatile(tab, ((long)i << ASHIFT) + ABASE); in tabAt()
768 return U.compareAndSwapObject(tab, ((long)i << ASHIFT) + ABASE, c, v); in casTabAt()
772 U.putObjectVolatile(tab, ((long)i << ASHIFT) + ABASE, v); in setTabAt()
2297 else if (U.compareAndSwapInt(this, SIZECTL, sc, -1)) { in initTable()
2328 !U.compareAndSwapLong(this, BASECOUNT, b = baseCount, s = b + x)) { in addCount()
2334 U.compareAndSwapLong(a, CELLVALUE, v = a.value, v + x))) { in addCount()
2352 if (U.compareAndSwapInt(this, SIZECTL, sc, sc + 1)) in addCount()
2355 else if (U.compareAndSwapInt(this, SIZECTL, sc, in addCount()
2376 if (U.compareAndSwapInt(this, SIZECTL, sc, sc + 1)) { in helpTransfer()
2399 if (U.compareAndSwapInt(this, SIZECTL, sc, -1)) { in tryPresize()
[all …]
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStreamTestScenario.java46 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_FOR_EACH_WITH_CLOSE()
47 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_FOR_EACH_WITH_CLOSE()
48 Stream<U> s = m.apply(data.stream()); in STREAM_FOR_EACH_WITH_CLOSE()
59 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_COLLECT()
60 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_COLLECT()
61 for (U t : m.apply(data.stream()).collect(Collectors.toList())) { in STREAM_COLLECT()
69 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_TO_ARRAY()
70 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_TO_ARRAY()
72 b.accept((U) t); in STREAM_TO_ARRAY()
79 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_ITERATOR()
[all …]
DOpTestCase.java97 <T, U, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
98 void run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, S_OUT> m); in run()
101 protected <T, U, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
102 Collection<U> exerciseOps(TestData<T, S_IN> data, Function<S_IN, S_OUT> m) { in exerciseOps()
109 protected final<T, U, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
110 Collection<U> exerciseOpsMulti(TestData<T, S_IN> data, in exerciseOpsMulti()
112 Collection<U> result = null; in exerciseOpsMulti()
117 Collection<U> r2 = withData(data).stream(m).exercise(); in exerciseOpsMulti()
144 protected final<T, U, R, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
185 protected <T, U, S_OUT extends BaseStream<U, S_OUT>>
[all …]
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStreamTestScenario.java49 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_FOR_EACH_WITH_CLOSE()
50 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_FOR_EACH_WITH_CLOSE()
51 Stream<U> s = m.apply(data.stream()); in STREAM_FOR_EACH_WITH_CLOSE()
62 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_COLLECT()
63 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_COLLECT()
64 for (U t : m.apply(data.stream()).collect(Collectors.toList())) { in STREAM_COLLECT()
72 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_TO_ARRAY()
73 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_TO_ARRAY()
75 b.accept((U) t); in STREAM_TO_ARRAY()
82 <T, U, S_IN extends BaseStream<T, S_IN>> in STREAM_ITERATOR()
[all …]
DOpTestCase.java98 <T, U, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
99 void run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, S_OUT> m); in run()
102 protected <T, U, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
103 Collection<U> exerciseOps(TestData<T, S_IN> data, Function<S_IN, S_OUT> m) { in exerciseOps()
110 protected final<T, U, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
111 Collection<U> exerciseOpsMulti(TestData<T, S_IN> data, in exerciseOpsMulti()
113 Collection<U> result = null; in exerciseOpsMulti()
118 Collection<U> r2 = withData(data).stream(m).exercise(); in exerciseOpsMulti()
145 protected final<T, U, R, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
186 protected <T, U, S_OUT extends BaseStream<U, S_OUT>>
[all …]
/libcore/ojluni/annotations/mmodule/java/util/concurrent/
DCompletableFuture.annotated.java46 public static <U> java.util.concurrent.CompletableFuture<U> supplyAsync(java.util.function.Supplier… in supplyAsync()
48 public static <U> java.util.concurrent.CompletableFuture<U> supplyAsync(java.util.function.Supplier… in supplyAsync()
54 public static <U> java.util.concurrent.CompletableFuture<U> completedFuture(U value) { throw new Ru… in completedFuture()
70 public <U> java.util.concurrent.CompletableFuture<U> thenApply(java.util.function.Function<? super … in thenApply()
72 public <U> java.util.concurrent.CompletableFuture<U> thenApplyAsync(java.util.function.Function<? s… in thenApplyAsync()
74 public <U> java.util.concurrent.CompletableFuture<U> thenApplyAsync(java.util.function.Function<? s… in thenApplyAsync()
88 …U, V> java.util.concurrent.CompletableFuture<V> thenCombine(java.util.concurrent.CompletionStage<?… in thenCombine() argument
90 …U, V> java.util.concurrent.CompletableFuture<V> thenCombineAsync(java.util.concurrent.CompletionSt… in thenCombineAsync() argument
92 …U, V> java.util.concurrent.CompletableFuture<V> thenCombineAsync(java.util.concurrent.CompletionSt… in thenCombineAsync() argument
94 …U> java.util.concurrent.CompletableFuture<java.lang.Void> thenAcceptBoth(java.util.concurrent.Comp… in thenAcceptBoth()
[all …]
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DLockSupport.java140 U.putObject(t, PARKBLOCKER, arg); in setBlocker()
156 U.unpark(thread); in unpark()
190 U.park(false, 0L); in park()
230 U.park(false, nanos); in parkNanos()
271 U.park(true, deadline); in parkUntil()
290 return U.getObjectVolatile(t, PARKBLOCKER); in getBlocker()
319 U.park(false, 0L); in park()
353 U.park(false, nanos); in parkNanos()
387 U.park(true, deadline); in parkUntil()
397 if ((r = U.getInt(t, SECONDARY)) != 0) { in nextSecondarySeed()
[all …]
DStampedLock.java349 U.compareAndSwapLong(this, STATE, s, next = s + WBIT)) ? in writeLock()
362 U.compareAndSwapLong(this, STATE, s, next = s + WBIT)) ? in tryWriteLock()
423 U.compareAndSwapLong(this, STATE, s, next = s + RUNIT)) ? in readLock()
439 if (U.compareAndSwapLong(this, STATE, s, next = s + RUNIT)) in tryReadLock()
467 if (U.compareAndSwapLong(this, STATE, s, next = s + RUNIT)) in tryReadLock()
525 U.loadFence(); in validate()
541 U.putLongVolatile(this, STATE, (stamp += WBIT) == 0L ? ORIGIN : stamp); in unlockWrite()
561 if (U.compareAndSwapLong(this, STATE, s, s - RUNIT)) { in unlockRead()
588 U.putLongVolatile(this, STATE, (s += WBIT) == 0L ? ORIGIN : s); in unlock()
596 if (U.compareAndSwapLong(this, STATE, s, s - RUNIT)) { in unlock()
[all …]
/libcore/ojluni/src/main/java/java/util/function/
DBiPredicate.java43 public interface BiPredicate<T, U> {
53 boolean test(T t, U u); in test()
71 default BiPredicate<T, U> and(BiPredicate<? super T, ? super U> other) { in and()
73 return (T t, U u) -> test(t, u) && other.test(t, u); in and()
83 default BiPredicate<T, U> negate() { in negate()
84 return (T t, U u) -> !test(t, u); in negate()
103 default BiPredicate<T, U> or(BiPredicate<? super T, ? super U> other) { in or()
105 return (T t, U u) -> test(t, u) || other.test(t, u); in or()
DBiConsumer.java45 public interface BiConsumer<T, U> {
53 void accept(T t, U u); in accept()
67 default BiConsumer<T, U> andThen(BiConsumer<? super T, ? super U> after) { in andThen()
/libcore/ojluni/src/main/java/java/util/concurrent/atomic/
DAtomicLong.java57 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicLong
76 VALUE = U.objectFieldOffset
117 U.putLongVolatile(this, VALUE, newValue); in set()
127 U.putOrderedLong(this, VALUE, newValue); in lazySet()
137 return U.getAndSetLong(this, VALUE, newValue); in getAndSet()
150 return U.compareAndSwapLong(this, VALUE, expect, update); in compareAndSet()
166 return U.compareAndSwapLong(this, VALUE, expect, update); in weakCompareAndSet()
175 return U.getAndAddLong(this, VALUE, 1L); in getAndIncrement()
184 return U.getAndAddLong(this, VALUE, -1L); in getAndDecrement()
194 return U.getAndAddLong(this, VALUE, delta); in getAndAdd()
[all …]
DAtomicInteger.java57 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicInteger
62 VALUE = U.objectFieldOffset
111 U.putOrderedInt(this, VALUE, newValue); in lazySet()
121 return U.getAndSetInt(this, VALUE, newValue); in getAndSet()
134 return U.compareAndSwapInt(this, VALUE, expect, update); in compareAndSet()
150 return U.compareAndSwapInt(this, VALUE, expect, update); in weakCompareAndSet()
159 return U.getAndAddInt(this, VALUE, 1); in getAndIncrement()
168 return U.getAndAddInt(this, VALUE, -1); in getAndDecrement()
178 return U.getAndAddInt(this, VALUE, delta); in getAndAdd()
187 return U.getAndAddInt(this, VALUE, 1) + 1; in incrementAndGet()
[all …]
DAtomicLongFieldUpdater.java84 public static <U> AtomicLongFieldUpdater<U> newUpdater(Class<U> tclass, in newUpdater()
88 return new CASUpdater<U>(tclass, fieldName, caller); in newUpdater()
90 return new LockedUpdater<U>(tclass, fieldName, caller); in newUpdater()
369 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicLongFieldUpdater.CASUpdater
423 this.offset = U.objectFieldOffset(field); in CASUpdater()
455 return U.compareAndSwapLong(obj, offset, expect, update); in compareAndSet()
460 return U.compareAndSwapLong(obj, offset, expect, update); in weakCompareAndSet()
465 U.putLongVolatile(obj, offset, newValue); in set()
470 U.putOrderedLong(obj, offset, newValue); in lazySet()
475 return U.getLongVolatile(obj, offset); in get()
[all …]
DStriped64.java128 return U.compareAndSwapLong(this, VALUE, cmp, val); in cas()
131 U.putLongVolatile(this, VALUE, 0L); in reset()
134 U.putLongVolatile(this, VALUE, identity); in reset()
138 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in Striped64.Cell
142 VALUE = U.objectFieldOffset
179 return U.compareAndSwapLong(this, BASE, cmp, val); in casBase()
186 return U.compareAndSwapInt(this, CELLSBUSY, 0, 1); in casCellsBusy()
194 return U.getInt(Thread.currentThread(), PROBE); in getProbe()
206 U.putInt(Thread.currentThread(), PROBE, probe); in advanceProbe()
377 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in Striped64
[all …]
DAtomicBoolean.java52 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicBoolean
57 VALUE = U.objectFieldOffset
100 return U.compareAndSwapInt(this, VALUE, in compareAndSet()
118 return U.compareAndSwapInt(this, VALUE, in weakCompareAndSet()
139 U.putOrderedInt(this, VALUE, (newValue ? 1 : 0)); in lazySet()
DAtomicIntegerFieldUpdater.java84 public static <U> AtomicIntegerFieldUpdater<U> newUpdater(Class<U> tclass, in newUpdater()
86 return new AtomicIntegerFieldUpdaterImpl<U> in newUpdater()
370 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicIntegerFieldUpdater.AtomicIntegerFieldUpdaterImpl
428 this.offset = U.objectFieldOffset(field); in AtomicIntegerFieldUpdaterImpl()
480 return U.compareAndSwapInt(obj, offset, expect, update); in compareAndSet()
485 return U.compareAndSwapInt(obj, offset, expect, update); in weakCompareAndSet()
490 U.putIntVolatile(obj, offset, newValue); in set()
495 U.putOrderedInt(obj, offset, newValue); in lazySet()
500 return U.getIntVolatile(obj, offset); in get()
505 return U.getAndSetInt(obj, offset, newValue); in getAndSet()
[all …]
DAtomicIntegerArray.java52 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicIntegerArray
58 ABASE = U.arrayBaseOffset(int[].class);
59 int scale = U.arrayIndexScale(int[].class);
118 return U.getIntVolatile(array, offset); in getRaw()
128 U.putIntVolatile(array, checkedByteOffset(i), newValue); in set()
139 U.putOrderedInt(array, checkedByteOffset(i), newValue); in lazySet()
151 return U.getAndSetInt(array, checkedByteOffset(i), newValue); in getAndSet()
169 return U.compareAndSwapInt(array, offset, expect, update); in compareAndSetRaw()
217 return U.getAndAddInt(array, checkedByteOffset(i), delta); in getAndAdd()
DAtomicLongArray.java51 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicLongArray
57 ABASE = U.arrayBaseOffset(long[].class);
58 int scale = U.arrayIndexScale(long[].class);
117 return U.getLongVolatile(array, offset); in getRaw()
127 U.putLongVolatile(array, checkedByteOffset(i), newValue); in set()
138 U.putOrderedLong(array, checkedByteOffset(i), newValue); in lazySet()
150 return U.getAndSetLong(array, checkedByteOffset(i), newValue); in getAndSet()
168 return U.compareAndSwapLong(array, offset, expect, update); in compareAndSetRaw()
216 return U.getAndAddLong(array, checkedByteOffset(i), delta); in getAndAdd()
DAtomicReferenceArray.java55 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicReferenceArray
63 ARRAY = U.objectFieldOffset
65 ABASE = U.arrayBaseOffset(Object[].class);
66 int scale = U.arrayIndexScale(Object[].class);
129 return (E) U.getObjectVolatile(array, offset); in getRaw()
139 U.putObjectVolatile(array, checkedByteOffset(i), newValue); in set()
150 U.putOrderedObject(array, checkedByteOffset(i), newValue); in lazySet()
163 return (E)U.getAndSetObject(array, checkedByteOffset(i), newValue); in getAndSet()
181 return U.compareAndSwapObject(array, offset, expect, update); in compareAndSetRaw()
329 U.putObjectVolatile(this, ARRAY, a); in readObject()
/libcore/ojluni/src/main/java/java/util/
DComparator.java238 default <U> Comparator<T> thenComparing( in thenComparing()
239 Function<? super T, ? extends U> keyExtractor, in thenComparing()
240 Comparator<? super U> keyComparator) in thenComparing()
262 default <U extends Comparable<? super U>> Comparator<T> thenComparing( in thenComparing()
263 Function<? super T, ? extends U> keyExtractor) in thenComparing()
429 public static <T, U> Comparator<T> comparing( in comparing()
430 Function<? super T, ? extends U> keyExtractor, in comparing()
431 Comparator<? super U> keyComparator) in comparing()
464 public static <T, U extends Comparable<? super U>> Comparator<T> comparing( in comparing()
465 Function<? super T, ? extends U> keyExtractor) in comparing()
/libcore/ojluni/annotations/sdk/nullability/java/util/concurrent/
DConcurrentHashMap.annotated.java132 …U> void forEach(long parallelismThreshold, @libcore.util.NonNull java.util.function.BiFunction<? s… in forEach()
134 …U> U search(long parallelismThreshold, @libcore.util.NonNull java.util.function.BiFunction<? super… in search()
136 …U> U reduce(long parallelismThreshold, @libcore.util.NonNull java.util.function.BiFunction<? super… in reduce() argument
146 …U> void forEachKey(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<? … in forEachKey()
148 …U> U searchKeys(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<? sup… in searchKeys()
152 …U> U reduceKeys(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<? sup… in reduceKeys() argument
162 …U> void forEachValue(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<… in forEachValue()
164 …U> U searchValues(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<? s… in searchValues()
168 …U> U reduceValues(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<? s… in reduceValues() argument
178 …U> void forEachEntry(long parallelismThreshold, @libcore.util.NonNull java.util.function.Function<… in forEachEntry()
[all …]

1234