Home
last modified time | relevance | path

Searched refs:U (Results 1 – 25 of 77) 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 …]
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 …]
DForkJoinWorkerThread.java95 U.putOrderedObject(this, INHERITEDACCESSCONTROLCONTEXT, acc); in ForkJoinWorkerThread()
177 U.putObject(this, THREADLOCALS, null); in eraseThreadLocals()
178 U.putObject(this, INHERITABLETHREADLOCALS, null); in eraseThreadLocals()
188 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in ForkJoinWorkerThread
194 THREADLOCALS = U.objectFieldOffset
196 INHERITABLETHREADLOCALS = U.objectFieldOffset
198 INHERITEDACCESSCONTROLCONTEXT = U.objectFieldOffset
DCountedCompleter.java527 U.getAndAddInt(this, PENDING, delta); in addToPendingCount()
539 return U.compareAndSwapInt(this, PENDING, expected, count); in compareAndSetPendingCount()
551 !U.compareAndSwapInt(this, PENDING, c, c - 1)); in decrementPendingCountUnlessZero()
584 else if (U.compareAndSwapInt(a, PENDING, c, c - 1)) in tryComplete()
607 else if (U.compareAndSwapInt(a, PENDING, c, c - 1)) in propagateCompletion()
652 else if (U.compareAndSwapInt(this, PENDING, c, c - 1)) in firstComplete()
757 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in CountedCompleter
761 PENDING = U.objectFieldOffset
/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/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/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/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()
DBiFunction.java44 public interface BiFunction<T, U, R> {
53 R apply(T t, U u); in apply()
68 default <V> BiFunction<T, U, V> andThen(Function<? super R, ? extends V> after) { in andThen()
70 return (T t, U u) -> after.apply(apply(t, u)); in andThen()
/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/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 …]
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()
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 …]
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()
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 …]
DAtomicReferenceFieldUpdater.java105 public static <U,W> AtomicReferenceFieldUpdater<U,W> newUpdater(Class<U> tclass, in newUpdater()
108 return new AtomicReferenceFieldUpdaterImpl<U,W> in newUpdater()
287 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicReferenceFieldUpdater.AtomicReferenceFieldUpdaterImpl
362 this.offset = U.objectFieldOffset(field); in AtomicReferenceFieldUpdaterImpl()
423 return U.compareAndSwapObject(obj, offset, expect, update); in compareAndSet()
430 return U.compareAndSwapObject(obj, offset, expect, update); in weakCompareAndSet()
436 U.putObjectVolatile(obj, offset, newValue); in set()
442 U.putOrderedObject(obj, offset, newValue); in lazySet()
448 return (V)U.getObjectVolatile(obj, offset); in get()
455 return (V)U.getAndSetObject(obj, offset, newValue); in getAndSet()
/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()

1234