本文整理了Java中io.trane.future.Future.value()
方法的一些代码示例,展示了Future.value()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.value()
方法的具体详情如下:
包路径:io.trane.future.Future
类名称:Future
方法名:value
[英]Creates a successful future.
[中]创造成功的未来。
代码示例来源:origin: traneio/ndbc
static <T> Exchange<T> value(final T v) {
return channel -> Future.value(v);
}
代码示例来源:origin: traneio/future
private Future<Integer> loop(int i) {
return Tailrec.apply(() -> {
if (i > 0)
return Future.value(i - 1).flatMap(this::loop);
else
return Future.value(0);
});
}
代码示例来源:origin: traneio/future
@Override
public final void onValue(final T value) {
becomeIfEmpty(Future.value(value));
}
代码示例来源:origin: traneio/future
@Benchmark
public Future<String> value() {
return Future.value(string);
}
代码示例来源:origin: traneio/future
@Override
public final void onValue(final T value) {
task.cancel(false);
becomeIfEmpty(Future.value(value));
}
代码示例来源:origin: traneio/future
static final Future<Void> VOID = Future.value((Void) null);
static final Future<Boolean> FALSE = Future.value(false);
static final Future<Boolean> TRUE = Future.value(true);
代码示例来源:origin: traneio/ndbc
@Override
public Future<T> acquire() {
if (closed)
return Future.exception(new RuntimeException("Pool closed"));
else {
final T item = items.poll();
if (item != null)
return Future.value(item);
else if (sizeSemaphore.tryAcquire()) {
final Future<T> conn = supplier.get();
return connectionTimeout.map(t -> conn.within(t, scheduler)).orElse(conn);
} else if (waitersSemaphore.tryAcquire()) {
final Promise<T> p = Promise.apply();
waiters.offer(p);
return p;
} else
return Future.exception(new RuntimeException("Pool exhausted"));
}
}
代码示例来源:origin: traneio/future
/**
* Selects the index of the first satisfied future.
*
* @param list the list of futures to select from
* @return a future with the index of the first satisfied future of the list.
*/
public static <T> Future<Integer> selectIndex(final List<Future<T>> list) {
switch (list.size()) {
case 0:
return Future.exception(new IllegalArgumentException("Can't select from empty list."));
case 1:
return list.get(0).map(v -> 0);
default:
final Promise<Integer> p = Promise.apply(list);
int i = 0;
for (final Future<?> f : list) {
if (f instanceof SatisfiedFuture)
return Future.value(i);
final int ii = i;
f.ensure(() -> p.becomeIfEmpty(Future.value(ii)));
i++;
}
return p;
}
}
内容来源于网络,如有侵权,请联系作者删除!