Home
last modified time | relevance | path

Searched refs:U (Results 1 – 25 of 78) 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.java363 Node q = (Node)U.getObjectVolatile(a, j = (i << ASHIFT) + ABASE); in arenaExchange()
364 if (q != null && U.compareAndSwapObject(a, j, q, null)) { in arenaExchange()
369 U.unpark(w); in arenaExchange()
374 if (U.compareAndSwapObject(a, j, null, p)) { in arenaExchange()
380 U.putOrderedObject(p, MATCH, null); in arenaExchange()
393 else if (U.getObjectVolatile(a, j) != p) in arenaExchange()
398 U.putObject(t, BLOCKER, this); // emulate LockSupport in arenaExchange()
400 if (U.getObjectVolatile(a, j) == p) in arenaExchange()
401 U.park(false, ns); in arenaExchange()
403 U.putObject(t, BLOCKER, null); in arenaExchange()
[all …]
DCompletableFuture.java224 return U.compareAndSwapObject(this, RESULT, null, r); in internalComplete()
228 return U.compareAndSwapObject(this, STACK, cmp, val); in casStack()
235 return U.compareAndSwapObject(this, STACK, h, c); in tryPushStack()
255 return U.compareAndSwapObject(this, RESULT, null, in completeNull()
266 return U.compareAndSwapObject(this, RESULT, null, in completeValue()
281 return U.compareAndSwapObject(this, RESULT, null, in completeThrowable()
309 return U.compareAndSwapObject(this, RESULT, null, in completeThrowable()
339 return U.compareAndSwapObject(this, RESULT, null, in completeRelay()
457 U.putOrderedObject(c, NEXT, next); in lazySetNext()
1040 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 …]
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
/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/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.java85 public static <U> AtomicLongFieldUpdater<U> newUpdater(Class<U> tclass, in newUpdater()
89 return new CASUpdater<U>(tclass, fieldName, caller); in newUpdater()
91 return new LockedUpdater<U>(tclass, fieldName, caller); in newUpdater()
370 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicLongFieldUpdater.CASUpdater
413 this.offset = U.objectFieldOffset(field); in CASUpdater()
445 return U.compareAndSwapLong(obj, offset, expect, update); in compareAndSet()
450 return U.compareAndSwapLong(obj, offset, expect, update); in weakCompareAndSet()
455 U.putLongVolatile(obj, offset, newValue); in set()
460 U.putOrderedLong(obj, offset, newValue); in lazySet()
465 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.java127 return U.compareAndSwapLong(this, VALUE, cmp, val); in cas()
130 U.putLongVolatile(this, VALUE, 0L); in reset()
133 U.putLongVolatile(this, VALUE, identity); in reset()
137 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in Striped64.Cell
141 VALUE = U.objectFieldOffset
178 return U.compareAndSwapLong(this, BASE, cmp, val); in casBase()
185 return U.compareAndSwapInt(this, CELLSBUSY, 0, 1); in casCellsBusy()
193 return U.getInt(Thread.currentThread(), PROBE); in getProbe()
205 U.putInt(Thread.currentThread(), PROBE, probe); in advanceProbe()
376 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in Striped64
[all …]
DAtomicReferenceFieldUpdater.java106 public static <U,W> AtomicReferenceFieldUpdater<U,W> newUpdater(Class<U> tclass, in newUpdater()
109 return new AtomicReferenceFieldUpdaterImpl<U,W> in newUpdater()
288 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicReferenceFieldUpdater.AtomicReferenceFieldUpdaterImpl
352 this.offset = U.objectFieldOffset(field); in AtomicReferenceFieldUpdaterImpl()
412 return U.compareAndSwapObject(obj, offset, expect, update); in compareAndSet()
419 return U.compareAndSwapObject(obj, offset, expect, update); in weakCompareAndSet()
425 U.putObjectVolatile(obj, offset, newValue); in set()
431 U.putOrderedObject(obj, offset, newValue); in lazySet()
437 return (V)U.getObjectVolatile(obj, offset); in get()
444 return (V)U.getAndSetObject(obj, offset, newValue); in getAndSet()
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()
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()
DAtomicIntegerFieldUpdater.java85 public static <U> AtomicIntegerFieldUpdater<U> newUpdater(Class<U> tclass, in newUpdater()
87 return new AtomicIntegerFieldUpdaterImpl<U> in newUpdater()
371 private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe(); field in AtomicIntegerFieldUpdater.AtomicIntegerFieldUpdaterImpl
420 this.offset = U.objectFieldOffset(field); in AtomicIntegerFieldUpdaterImpl()
470 return U.compareAndSwapInt(obj, offset, expect, update); in compareAndSet()
475 return U.compareAndSwapInt(obj, offset, expect, update); in weakCompareAndSet()
480 U.putIntVolatile(obj, offset, newValue); in set()
485 U.putOrderedInt(obj, offset, newValue); in lazySet()
490 return U.getIntVolatile(obj, offset); in get()
495 return U.getAndSetInt(obj, offset, newValue); in getAndSet()
[all …]
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()

1234