- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
Project Reactor 提供了一种很好的方式来定义代码在哪个线程池上运行,通过定义 Scheduler
.它还为使用 CompletableFuture
的库提供了一座桥梁。的虽然Mono.fromFuture(..)
.
AWS 的 async client for DyanmoDB , 执行 CompletableFuture
是从对 java.util.concurrent.Executor
的 API 调用返回的吗? .默认情况下,它会创建一个 Executor
由它也创建的线程池支持。结果是即使流定义为 Scheduler
喜欢 Mono.fromFuture(..).subscribeOn(Schedulers.boundedElastic())
在库创建的池中的线程上执行,而不是在 Schedulers.boundedElastic()
中的线程上执行。 .所以我们看到像 sdk-async-response-0-2
这样的线程名称, 而不是像 boundedElastic-1
这样的名称.
幸运的是,该库允许我们提供自己的 Executor
作为 shown here ,所以我的问题是:
How do you build an
Executor
that uses a thread from theScheduler
defined on that part of the stream at runtime?
findById
方法,我们需要调用者能够控制哪个
Scheduler
继续运行,因为它在这些截然不同的上下文中使用:
Schedulers.boundedElastic()
上运行的 API 响应调度器。 Executor
使用
Schedulers.immediate()
和
Runnable::run
如此处所示,但两者都导致在 Netty 事件循环线程上执行(示例名称:
aws-java-sdk-NettyEventLoop-0-2
),而不是定义的
Scheduler
中的线程.
DynamoDbAsyncClient.builder()
.asyncConfiguration(builder -> builder.advancedOption(
SdkAdvancedAsyncClientOption.FUTURE_COMPLETION_EXECUTOR,
runnable -> Schedulers.immediate().schedule(runnable)
))
.build();
DynamoDbAsyncClient.builder()
.asyncConfiguration(builder -> builder.advancedOption(
SdkAdvancedAsyncClientOption.FUTURE_COMPLETION_EXECUTOR,
Runnable::run
))
.build();
最佳答案
第 1 部分。观察与订阅
调查这个问题,我认为需要 观察 在特定线程上执行后的元素。
准确地说,观察 在这种情况下,意味着*能够在某个特定线程上处理流中的值。在 RxJava 中,我们有一个正确的操作符,就像这样,但在 Project Reactor 中,我们将相同的操作称为 publishOn
.
因此,
* 如果要处理数据 * 在 Schedulers.boundedElastic()
那么你应该使用以下结构
Mono.fromFuture(..)
.publishOn(Schedulers.boundedElastic())
.subscribeOn
也有效???
Mono.fromRunnable(..)
.subscribeOn(Schedulers.boundedElastic())
onNext
在线程
boundedElastic-1
,那么相同的
fromFuture
有什么问题? .
subscribeOn
与
Futures
/
CompletableFuture
或任何可以在下面使用自己的异步机制的东西
subscribeOn
背后发生了什么,您会发现类似以下内容:
// Simplified version of SubscribeOn operator
@Override
public void subscribe(CoreSubscriber<? super T> actual) {
Scheduler scheduler;
Publisher<T> parent;
scheduler.schedule(() -> parent.subscribe(actual));
}
subscribe
方法将在单独的线程上调用。
fromRunnable
,
fromSupplier
,
fromCallable
因为他们的逻辑发生在
subscribe
方法:
@Override
public void subscribe(CoreSubscriber<? super T> actual) {
Operators.MonoSubscriber<T, T>
sds = new Operators.MonoSubscriber<>(actual);
actual.onSubscribe(sds);
// skiped some parts
T t = supplier.get();
if (t == null) {
sds.onComplete();
}
else {
sds.complete(t);
}
}
scheduler.schedule(() -> {
T t = supplier.get();
if (t == null) {
sds.onComplete();
}
else {
sds.complete(t);
}
})
fromFuture
工作更棘手。
var future = CompletableFuture
.supplyAsync(() -> {
return value;
})
... // some code here, does not metter just code
future.thenAccept(value -> {
System.out.println(Thread.currentThread())
});
volatile
阅读器线程(线程 Main)上的字段,否则,线程 Main 将设置
acceptor
所以稍后会在
ForkJoinPool
上调用接受器线。
fromFuture
与
subscribeOn
, 不保证
subscribeOn
线程将观察给定
CompletableFuture
的值.
publishOn
是确保值处理发生在所需线程上的唯一方法。
publishOn
一直往下???
Mono
- 在 99% 的情况下,您可以使用
publishOn
如果您想确保您的数据处理发生在特定线程上 - 请始终使用
publishOn
.
publishOn
与
subscribeOn
(如果它在不破坏行为的情况下是安全的)在运行时,所以你会得到最好的。
Scheduelr
的兔子洞s
Schedulers.immediate()
Schedulers.immediate().scheduler(runnable) {
runnable.run()
}
Executor
. (例如
Executors.fixed...
)
ScheduledExecutorService
如果你想获得周期性任务和延迟任务的力量
Scheduler
从您的执行人使用
Schedulers.fromExecutorXXX
API
Executor
在命令式世界中,使用您的
Scheduler
它是 react 世界的有界包装
关于java - 如何将 Project Reactor 的调度程序与基于 Executor 的库一起使用?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60783347/
Java 库和 android 库有什么区别,各自有什么优点/缺点? 最佳答案 您可以在 Android 应用程序中包含标准 Java .jar 文件库。它们在 .apk 构建时被翻译成 Dalvik
所以,我现在的代码就像从 Java 层加载库(比如 liba.so),并在内部 liba.so 加载 libb.so。因此,如果我必须将所有库打包到 APK 中并将其安装在没有 root 访问权限的设
我想在我的系统中设置 LEDA 库。 我已经从以下链接下载了 LEDA 库 http://www.algorithmic-solutions.info/free/d5.php Instruct
我想用 autoconf 创建一个共享库。但是,我希望共享库具有“.so”扩展名,而不是以“lib”开头。基本上,我想制作一个加载 dlopen 的插件。 .是否有捷径可寻? 当我尝试使用 autoc
我需要在 Apps 脚本应用程序上修改 PDF。为此,我想使用 JS 库:PDF-LIB 我的代码: eval(UrlFetchApp.fetch("https://unpkg.com/pdf-lib
我正在构建一个使用以下 Boost header 的程序(我使用的是 Microsoft Visual C++ 10), #include #include #include #include
当我通过 cygwin 在 hadoop 上运行此命令时: $bin/hadoop jar hadoop-examples-*.jar grep input output 'dfs[a-z.]+' 我
我已经通过 vcpgk 成功安装了一个 C++ 库,名为:lmdb:x64-windows 我还安装了lmdb通过 Cabal 安装的 Haskell 绑定(bind)包 在尝试测试 lmdb 包时:
我该如何解决这个问题? 我刚刚将 javacv jar 文件复制到我的项目 Lib 文件夹下,但出现了这个错误! 我可以找到这个thread来自谷歌,但不幸的是,由于我国的谷歌限制政策,该页面无法打开
我有一个 Android 库项目 FooLib。 FooLib 引用 Android Context 之类的东西,但不需要任何资源文件(res/ 中的东西)所以我目前将其打包为供我的应用使用的 JAR
我正在开发一个 Android 应用程序(使用 Android Studio),它能够通过手势识别算法了解您正在进行的 Activity 。对于我使用 nickgillian ithub 帐户上可用的
关于从 .NET Framework 项目中引用 .NET Standard 类库的问题有很多类似的问题,其中 netstandard 库中的 NuGet 包依赖项不会流向 netframework
我已经从互联网上下载了 jna-4.2.2.jar,现在想将这个 jar 导入到我的项目中。但是当我试图将这个 jar 导入我的项目时,出现以下错误。 [2016-06-20 09:35:01 - F
我正在尝试通过编译在 Mac 上安装 rsync 3.2.3。但是,我想安装所有功能。为此,它需要一些库,此处 ( https://download.samba.org/pub/rsync/INSTA
进入 Web 开发有点困难。过去 5 年我一直致力于 winforms 工作。所以我正在努力从一种切换到另一种。前段时间,我使用过 JavaScript,但现在还没有大量的 JavaScript 库
很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开,visit the help center . 关闭 1
我正在寻找一个用Python编写的与logstash(ruby + java)类似的工具/库。 我的目标是: 从 syslog 中解析所有系统日志 解析应用程序特定日志(apache、django、m
就目前情况而言,这个问题不太适合我们的问答形式。我们希望答案得到事实、引用资料或专业知识的支持,但这个问题可能会引发辩论、争论、民意调查或扩展讨论。如果您觉得这个问题可以改进并可能重新开放,visit
我花了几天时间试图寻找用于 JavaPOS 实现的 .jar 库,但我找不到任何可以工作的东西。我找到了很多像这样的文档:http://jpos.1045706.n5.nabble.com/file/
这个问题在这里已经有了答案: Merge multiple .so shared libraries (2 个答案) 关闭 9 年前。 我有我在代码中使用的第三方库的源代码和对象。该库附带有关如何使
我是一名优秀的程序员,十分优秀!