我正在学习Java for Android，以及我学到的一些关于线程和消息队列的东西，如下所示。我有一些问题，在C++中线程间的通信不是由处理程序完成的。我认为这是通过消息队列或管道完成的。我的问题是，在主线程和辅助线程之间的通信方面，我如何将Java语言中的处理程序概念与C++中
浏览 0提问于2013-07-25得票数 0
1回答
我需要将shell脚本(从基于linux的应用程序调用)的信息传递给java应用程序。
命名管道是一个痛苦的，因为如果不考虑对管道的读/写端的复杂影响，就无法启动/停止这两个服务。套接字是严格的，因为如果重新启动侦听过程，就没有排队机制，而且简单的实现需要不断地创建新的套接字(否则，shell脚本将变得非常复杂，包含检查和重新启动套接字以及队列代码)。我最近读到了关于这些系统V/POSIX消息队列的文章，。我正在运行Fedora 12，我想知道是否有一种很好的方法来配置这些消
浏览 1提问于2011-06-20得票数 6
回答已采纳
3回答
有人能给我提供PHP进程写入内存而Java进程从共享内存读取的链接或代码片段吗？编辑的问题:假设我在php中创建了一个共享内存，如下所示现在有一些方法可以用来传递$shm_id的值，然后在java中读取它。
浏览 0提问于2011-03-02得票数 4
回答已采纳
我有弹簧集成QueueChannel，我想消费在背压意识的通量管道。我不想使用Poller和调度程序提前从队列中提取消息。
在最新的+ Java/Kotlin中，通过错误恢复等，什么是最好的方法？
浏览 3提问于2021-03-25得票数 1
回答已采纳
1回答
是否可以使用activiti作为工作流前端，它使用kafka (或类似的事件队列)作为处理管道。这个是可能的吗？如果是，是如何实现的？
浏览 3提问于2018-04-23得票数 3
有3个守护进程线程的应用程序和4个单独的应用程序(多处理队列/管道和从队列/管道应用程序读取的3个守护进程线程应用程序)在线程操作功能上是否有区别？
“交易策略”：与feed交互(管道?
浏览 0提问于2016-10-21得票数 0
1回答
在包含SQS队列的数据管道中，我们的交付时间很慢。所以我想知道消息在SQS位上花费了多少时间。NumberOfEmptyReceivesNumberOfMessagesReceivedSentMessageSize
目前没有拥塞，队列99.99%的时间是空的，但不能保证每个消息在队列中花费一小段时间。是否有任何高级指标选项或任何外部工具或Scala/Java库来测量每个消息ID的Tconsume-Tpr
浏览 11提问于2016-07-27得票数 2
以前，我们的管道可以使用默认设置(内存队列、批处理大小125、每个内核一个工作人员)和每秒处理5k事件。我们向JSON记录中添加了一些数据，现在堆内存增加了，并在摄入一个小时后逐渐崩溃。
虽然这些都有所帮助，但它只是延迟了时间，直到内存问题开始出现。我该怎么做才能解决这个问题？
浏览 4提问于2022-01-20得票数 0
我有一个问题，我必须从管道中读取流数据，用C编写的应用程序将数据写入管道。另一个用java编写的应用程序必须从这个linux管道中读取数据。这个java程序是一个多线程程序，当其他程序将数据写入该管道时，它将从该管道读取数据。当数据被添加到管道队列时，它应该不断地从管道中读取。任何建议都会很有帮助。试图解决的问题是：
目前，一个应用程序(在C中)连续地将文件实时地创建到目录中，而另一个应用程序(在java</
浏览 147提问于2018-09-27得票数 0
我刚刚发现只有一个NIO工具，Java NIO管道，它是为在线程之间传递数据而设计的。与通过队列传递更传统的消息(如ArrayBlockingQueue )相比，使用此机制有什么优势吗？
浏览 2提问于2011-09-27得票数 11
回答已采纳
参考，我试图更改gstreamer管道上的udpsrc。但是有些地方出了问题，在更改udp源代码之后，不能将管道的状态更改为播放。
设置udpsrc空状态，并从管道箱中删除udpsrc。链接到队列
浏览 1提问于2015-07-15得票数 3
回答已采纳
在TensorFlow中，旧的输入管道使用了一系列队列，线程从这些队列中加入了排队和退出队列的元素。例如，文件名的string_input_producer队列，作为批处理的队列的tf.train.batch，等等。我已经从这个旧模型升级了我的数据输入管道，使用目前位于tf.contrib.data.TFRecordDataset中的新模型来读取我用来训练的TFRecord文件。，所以我的问题是：
新的输入管道是如何工作的？它根本不使用队列</
浏览 2提问于2017-07-12得票数 6
回答已采纳
我有一个与PipedInputStream和PipedOutputStream相关的问题，我不知道我是否误解了这些类的设计，或者PipedInputStream.java中的java代码中是否有bugJava中的Reader/Writer (自JDK1.1)比InputStream/OutputStream (自JDK1.0之后)更新。PipedInputStream中的protected可视化是继承自早期Java版本的设计意外吗?还是我完全迷失了方向？PD:这是一个出现这个问题的例子。i
浏览 0提问于2015-02-06得票数 1
4回答
我希望在不阻塞读取器的情况下写入命名管道(已创建)。我的阅读器是另一个可能会崩溃的应用程序。如果读取器确实关闭，我希望写入器应用程序继续写入该命名管道。Java中类似于this的东西因此，当读取器启动时，它可能会从失败的地方恢复。
浏览 1提问于2010-08-30得票数 9
我们有一个Azure DevOps服务器(在prem上)和不同的构建/发布管道。有没有办法同时暂停/恢复所有Azure管道</e
浏览 0提问于2020-09-14得票数 6
回答已采纳
一旦接收到字节，我就有了一个包含业务逻辑的管道，可以在接收到的字节上运行。此管道由多个通道处理程序组成，如报头解码器、应用层碎片处理程序等。在管道的末尾，一旦消息被处理，管道中的最后一个处理程序(例如BufferWriter)将把处理后的消息放入阻塞队列。这个阻塞队列的作用就像缓冲区，而BufferWriter就像生产者。请注意，此阻塞队列在所有通道之间共享。因此，应用程序接收到的所有数据都将写入单个队列。还有另一个调度的executor服务，它将作为
浏览 6提问于2018-11-23得票数 0
1回答
如何确定所有线程何时已完成执行？
、、、、
我有一个体系结构，它从打包的二进制文件中读取数据包，根据数据包类型将每个数据包分配给一个单独的处理管道，并将数据包重新组合成管道另一侧的一个新文件。每个管道包含类似于的阻塞队列。阻塞队列的每一侧都有一个线程，它运行一个循环，对数据包进行队列或排队列。这些线程是从控制器对象异步启动的(即“触发和忘记”样式)。此控制器对象具有包含所有管道对象的Dictionary<int, ChannelPipeline>集合。
以下是我的问题:当所有
浏览 2提问于2011-08-12得票数 3
回答已采纳
此模块使您能够定义队列/管道，并为创建的每个队列/管分配优先级值。
我想找出以下几点。假设我在Beanstalkd中有两个队列/管道(队列A和队列B)。如果分配给队列A的项比队列B中的项具有更高的优先级，这是否意味着队列B中的项只有在队列A为空时才会被处理？
浏览 2提问于2014-04-15得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
