问题标签 [processors]

我的程序是阶乘函数的简单递归实现。它的执行速度与我电脑上的处理器数量有关吗？我的程序不是多线程的。

我使用python并行处理器在Linux机器上提交了多个作业：（从多处理导入的池）

我有大约 4000 个工作 .. 最初几天它正在使用所有处理器，但它开始减少进程数量。目前，我还剩下大约 300 个工作，并且使用了 4 个进程。它没有使用完整的 10 个处理器

我的猜测是 python 最初将作业分配给所有处理器，并且一些处理器提前完成了它们的工作，现在处于空闲状态。

这是正确的假设吗？有没有办法解决这个问题，所以所有处理器都被利用到最后以更快地完成运行？

def run_parallel(self, my_jobs): #give the number of processors parallel = Pool(processes = 10) #run jobs in parallel parallel.map(run_jobs, my_jobs) return

我仍然对相关性有一些疑问： 1. 相关性可以通过预处理器实现 -> HTTP URL 重写修饰符和后处理器 -> 正则表达式提取器？2.如果是，那么两者的流程有什么区别？3.我浏览了很多链接，上面说可以通过正则表达式提取器实现相关性，所以请您对此有所了解。

我正在尝试解决一项任务，并将感谢任何帮助 - 文档链接，或论坛链接，或除https://cwiki.apache.org/confluence/display/NIFI/FAQs之外的其他常见问题解答，或任何有意义的答案这篇文章 =) 。

所以，我有以下任务：我系统的初始部分每 5-15 分钟从不同的数据库源收集数据。然后我删除重复项，删除垃圾，根据逻辑组合来自不同来源的数据，然后将其作为多个流重定向到系统的第二部分。据我所知，“NiFi”可以以最好的方式完成这项任务=）。

目前我可以通过“GetHTTP”处理器成功地从 InfluxDB 获取信息。但是，我无法配置相同类型的处理器来从 Elastic DB 获取所有必要选项的信息。我想每 5-15 分钟接收一次数据，时间段从“现在-减-<5-15 分钟>”到“现在”。（取决于调度程序周期）和几个额外的过滤器。如果我理解正确，这可以通过订阅“_index”或通过定期向 DB 请求所需间隔来实现。

我知道 NiFi 有几个为 Elasticsearch 设计的特定处理器（FetchElasticsearch5、FetchElasticsearchHttp、QueryElasticsearchHttp、ScrollElasticsearchHttp）以及 GetHTTP 和 PostHTTP 处理器。然而，不幸的是，我缺乏信息甚至更好的例子——如何为我的目的配置它们的“属性”=(。

FetchElasticsearchHttp、QueryElasticsearchHttp 有什么区别？哪一个更适合我的任务？GetHTTP 和 QueryElasticsearchHttp 除了几个特定字段外，还有什么区别？如果我根据需要对其进行调整，GetHTTP 会以相同的方式执行吗？

有什么建议吗？

我将不胜感激任何帮助。

ffmpeg4android 有一个问题，它只适用于 armeabi-v7a，是否可以选择让它适用于 x86、x86_64 和 arm64-v8a？Litteraly，不知道该怎么做，也许有一个选项可以让用户 arm64-v8a 向后兼容 armeabi-v7a？

目前我遇到了以下问题：我正在使用 KafkaConsumer 读取来自 Kafka 主题的消息。消息是字符串并具有以下格式： { "a" : "b", "a1" : "b1", "c2" : "c3" } 它们保存在 FlowFile 的有效负载中。

我想将该字符串转换为 json 或理想情况下转换为 csv，但不知道该怎么做。

我是 NiFi 的新手并尽可能多地进行了研究，但我发现的答案是关于从 json 到 avro 或类似的转换，但从不将字符串转换为 json 或 avro。我还发现 Kafka 消息在 FlowFile 的有效负载中，而不是在属性中，所以我不知道如何获得它，因为示例总是涉及属性。

简而言之：我可以使用一些内置处理器将 FlowFile 的有效负载（一个字符串）转换为 json/cvs。

我有以下架构的可执行二进制文件（不是共享库）：

• arm64-v8a

• 阿米亚比

• armeabi-v7a

• mips

• mips64

• x86

• x86_64

现在我是否需要将所有这些二进制文件放入我的 apk（将花费我 300kb），或者某些二进制文件可以在多个架构上运行？请建议我哪个可以在哪些处理器上运行。

Java 8，Spring Boot 2。我正在使用多线程和 CompletableFuture 测试性能时，我意识到只有 1 个核心处于阻塞状态，其余核心基本上没有做太多工作。 仅 1 个核心的高负载

其他内核上的一些负载可能是由机器上运行的其他进程引起的。我试图找出问题所在，然后意识到

在运行时总是返回 1。我是否启动了多个线程都没有关系，数字始终是 1（应该是 8）。然后我创建了简单的单元测试类并运行 availableProcessors() 代码并得到 8。显然，连接到 Spring 上下文的东西使运行时看不到所有可用的内核。帮助？

我Runtime.getRuntime.availableProcessors()用来创建我的线程池。在我们自己的物理数据中心上，它曾经返回的 cpu 数为 8，并且从未更改过。然后每次有请求（数据密集型）进入时，我们使用相同的可用处理器 API 对数据进行分区，并且该线程池的每个线程都处理其中一个分区。

然而，最近我们切换到 AWS（和 Docker 作为容器），每次请求（数据密集型）来，并且想要对数据进行分区并因此调用该 API 时，它都会返回一个不同的数字。例子：

使用的分区数：[X = 12] [Y= 15] [Z = 12] [W = 5] [Q = 15] [P = 3]

情况不妙。如果在我们创建线程池的时候可用处理器是 3，而当请求进来并且我们对数据进行分区时，它是 15。

我知道 API 文档说：

返回 Java 虚拟机可用的处理器数量。

此值可能会在虚拟机的特定调用期间发生变化。因此，对可用处理器数量敏感的应用程序应偶尔轮询此属性并适当调整其资源使用情况。

但我的问题是

1. 为什么它以前没有改变（总是返回 8），为什么它在 AWS 上变化如此之大，以及是否有办法解决它？
2. 如果没有办法修复它，我该如何修改应用程序以确保线程池和分区兼容？

谢谢

我想对一些处理器内核进行编程，以按照我定义的方式执行任务。
怎么做？我怎样才能编写一个程序来做到这一点？这对我有用吗

我需要做汇编语言编程吗？
如果是，那么如何？

有没有人有什么建议？