《多线程》专题

我只是想知道是否有可能替换用Java的Executor服务编写的旧的多线程代码到Akka。我对此没有什么疑问。 目前我使用固定线程池多线程，并提交一个可调用的。 示例代码, 但没有解释它如何变得比线程更快？ 我尝试了一些示例Akka（activator中的Akka示例）代码，并在所有Actor中打印了Thread.currentThread.getName，发现创建了名为（helloakka-ak

我有一个多步骤Spring Batch作业，在其中一个步骤中，我为在阅读器中读取的数据创建Lucene索引，以便后续步骤可以在该Lucene索引中搜索。 基于中读取的数据，我将索引分散到几个单独的目录中。 如果我指定Step Task Executor为，只要索引总是写入不同的目录，我就不会遇到任何问题，但有时会出现锁定异常。我猜，两个线程试图写入同一个索引。 如果我删除了，我不会遇到任何问题，但

如果队列已满，ArrayBlockingQueue将阻止生产者线程；如果队列为空，ArrayBlockingQueue将阻止消费者线程。 这种阻塞的概念是否与多线程的思想背道而驰？如果我有一个“主”线程，并假设我想将所有“日志记录”活动委托给另一个线程。因此，基本上在我的主线程内，我创建了一个Runnable来记录输出，并将其放在ArrayBlockingQueue上。这样做的全部目的是让“主”线

一个关于在java中使用线程的问题（免责声明——我对线程不是很有经验，所以请允许一些回旋余地）。 概述：我想知道是否有一种方法可以让多个线程向另一个线程负责的队列中添加要执行的操作。实际上，顺序并不重要——更重要的是，队列中的操作一次处理一个。 说明：我计划托管一个小型服务器（使用servlet）。我希望与客户机的每个连接都由一个单独的线程处理（到目前为止还可以）。但是，这些线程/客户端中的每一个

我有一个spring批处理作业，它接收平面文件，处理记录，并将输出写入另一个平面文件。我分别使用了和作为读写器。然而，当我尝试实现多线程步骤时，我的工作无法正常工作。我在日志文件中收到以下警告 你能帮我实现多线程步骤吗？

我真的被系统搞糊涂了。python中的exit（）。在python文档中，它表示“退出python”；这是否意味着当在python程序中被调用，进程将退出吗？如果是，下面的代码将显示不同的结果： 在linux中启动这个程序，结果并不像python文档所说的那样是预期的，但仍然在系统中运行，所以真的要退出吗？

消费者是一个spring集成项目，它从消息队列中消费并执行大量处理。目前，它是单线程的，不能与生产者发送消息的速度匹配。因此队列深度不断增加 是否可以使用executor通道在多线程环境中处理此问题并加快使用者进程 如果是，请建议如何实现--为了确保消息的顺序，我需要将相同类型的消息（基于消息的id）分配给executor通道的相同线程。 因此executor通道上的BridgeTo将转发消息

这里我用java开发。 我有一个for循环中的线程，我想连续运行5次。不幸的是，循环在第二次运行时停止，出现了一个错误： 异常在线程"main"java.lang.IllegalThreadStateExctive在java.base/java.lang.Thread.start（Thread.java:793） 我知道这个错误是什么意思，但是我要求他在确定完成线程时恢复循环，这样就不会有任何错误

首先，根据句子的大小，解析在小的句子集上平稳运行--从200ms到1s的顺序。 我想实现什么？ 我想在1-2小时内解析50L个句子。 不知怎么的，我需要把这个转换成-> 转换为多线程调用。我编写了一个多线程执行器来做这件事，它看起来像这样-> 有什么办法可以做到吗？我能回答先前提出的问题，但没有什么好处。

运行之后（在jdk1.8中），答案不是1000。请告诉我原因。

--编辑1-- 音频和视频来自外部来源（麦克风和摄像机），并被捕获为未经任何压缩的原始数据（即使是视频）。我使用h264编码视频和音频无压缩(PCM)。 捕获的音频为：16位，44100kHz，立体声 谢谢你宝贵的建议。

在多个线程中使用cout可能会导致交叉输出<所以我试着用互斥来保护cout。 以下代码使用std:：async启动10个后台线程。当线程启动时，它会打印“已启动线程…”。主线程按照创建后台线程的顺序迭代这些线程的未来，并打印出“donethread…”当相应的线程完成时。 输出是正确同步的，但是在一些线程已经启动，一些线程已经完成（请参见下面的输出）之后，会发生死锁。所有后台线程都已离开，主线程正

RabbitMQ保证在相同的发布通道- 1.）我有一个单一的线程发布消息在一个单一的交换2.（我有其他线程的集合发布消息在不同的交流有时创造新的消费者为不同的交流 使用缓存连接工厂，它具有通道缓存。每次发布时，它都会进入缓存以获取通道。因为其他线程正在发布和使用，所以不能保证同一通道将被我的主线程用于后续发布。即使我有一个缓存，这也是真的。有人回避过这个问题吗？ 理想情况下，我希望为publish

如何使这个多线程。？

我搜索了关于测量Java应用程序执行时间的信息，得到了以下代码： 开始和停止之间的差异给了我执行时间。 注意：我知道这不是确切的执行时间。我只是需要多线程和单线程应用程序之间的比较的时间。 如果我这样更改代码会怎样： 执行10个线程。不管他们做什么。假设他们随机填充一个二维数组。 现在，stop-start给了我“全部”执行时间？或者我必须自己测量线程吗？