有时会发生一个线程完成读取文件的情况。在他关闭阅读器的那一刻，另一个线程就会出现，并试图从与阅读器关联的同一个流中进行读取。喜欢我怎样才能为不同的线程创建单独的流。
浏览 2提问于2011-11-25得票数 1
回答已采纳
2回答
是否可以在调用者线程以外的同一线程中订阅两个不同的流？
假设我有两个不同的观察体和两个不同的订阅者。我在两个观察点上都调用了subscribeOn(Schedulers.newThread())。但我希望他们订阅同一个线程，而不是两个不同的线程。
浏览 7提问于2016-09-17得票数 2
回答已采纳
我有一个CUDA内核来完成我的繁重工作，但我也有一些繁重的工作需要在CPU中完成(同一数组的两个位置的计算)，我无法在CUDA中编写(因为CUDA线程不同步，所以我需要在一个数组的位置X上执行一个繁重的工作，然后执行zx = yx - yx - 1，其中y是CUDA内核的数组结果，其中每个线程都在这个数组的一个位置上工作，z是存储结果的另一个数组)。所以我在CPU中做这件事。
我有几个CPU线程来做CPU端的工作，但每个线程<
浏览 3提问于2012-10-25得票数 3
回答已采纳
我想将kafka流处理并行化。但是我不想放到Runnable中，我也不想多次启动这个应用程序。
有没有像streams.parallel()这样的方法？
浏览 0提问于2018-08-09得票数 1
2回答
单个工作流启动多个工作流
、、、
日安，
我有一个列表，它有一个在创建idem时启动的自定义工作流。在工作流中，我有一个在列表上创建多个项目的codeActivity。这又会启动多个工作流。我遇到一个问题，当子工作流中的一个无法启动时，父项目工作流的状态将从“正在进行”更改为“发生错误”。它们似乎是在同一个线程下启动的。如何启动子工作流以使其独
浏览 2提问于2014-09-11得票数 0
1回答
Python中的工作流框架
、、、、
我试图在Python中创建具有以下特性的工作流：
在Windows上工作。据我所知，在许多工作流框架中，似乎1)和3)是可以实现的，但是2)并不是那么容易。在我的研究中，我主要关注的是Celery & Luigi框架。对于Cele
浏览 0提问于2019-01-02得票数 0
3回答
我最近遇到过一些情况，服务器会为所有监听器分发包含完全相同数据的事件流，例如“最近的活动”框。我突然想到，让Apache这样的服务器运行一个线程来处理和查询数据库中包含相同数据的每个comet流，这是非常奇怪和低效的。对于这些全局(而不是每个用户)流，我要做的是运行一个连续发出数据的线程，并为每个新请求运行一个新的(绿色)线程，该线程输出头部，然后“合并”到主线程中</em
浏览 7提问于2010-06-17得票数 1
回答已采纳
在gevent文档中：
greenlets都在同一个OS线程中运行，并且是协同调度的。那么，是否仍然需要使用gevent锁原语或gevent.Queue来避免单个线程中多个小线程之间的争用条件？最好举个例子来证明这样的比赛条件。根据我自己的理解，这些同步原语似乎只是在greentlet之间切换执行流的一种方式。
浏览 2提问于2017-10-02得票数 2
回答已采纳
1回答
我在Cuda中实现了RNS Montgomery指数运算。但是，到目前为止，我只关注单个exp的并行化。我现在想做的是在飞行中测试几个exp。
浏览 6提问于2012-08-28得票数 0
回答已采纳
1回答
假设我有多个应用相同谓词集的源流。我希望设置分支流，以便满足谓词的记录，无论哪个源流，都由同一个分支流处理。如下图所示，每个分支流都像一个通用处理器，它转换传入记录。
平均分配消息数量的分支。但是，如下面的代码块所示，所有叉流都存在于同一个线
浏览 0提问于2018-11-24得票数 0
回答已采纳
目前，我有一个红流，其中有许多条目产生。我想并行地处理流，但确保每个条目只处理一次()。我搜索有关redis 的官方文档。消费者群体似乎是一种解决方案。因此，我尝试创建一个使用者组，让该组中的多个使用者并行地使用相同的流(可能是不同服务器上的多个使用者实例，也可能是同一服务器中的多个线程)。Redis消费者组能否保证并行运行的多消费者使用来自同一流的不同排他子集，
浏览 4提问于2021-11-22得票数 0
回答已采纳
1回答
通过在同一流中创建多个事务生成器，尝试创建事务包以利用单个流线程。我们注意到flow类返回一个signedTransaction。
有没有一种方法可以在单个流中创建多个事务构建器？
浏览 1提问于2019-07-19得票数 0
回答已采纳
2回答
C++流对象线程安全？
、、、、
我需要在C++应用程序中包含多个线程的文件夹中的文件中提供文本搜索。如果两个线程试图在只读模式下打开同一个文件，会导致数据竞争还是多个线程可以使用流对象读取文件？std::ifstream ifs ("test.txt");此外，文件夹中的文件是动态的(在应用程序运行
浏览 5提问于2014-04-26得票数 1
回答已采纳
我有一个能够同时生成5个mpeg传输流的程序。每个流都有自己的上下文，并在一个独立的线程中完成。当只有一个流处于活动状态时，一切都会正常工作。一旦我激活另一个流，我的帧率就会大大下降。这两个流仍然正常工作，只是帧速率很慢。我追踪到了给av_interleaved_write_frame的电话。它从单个流的大约4毫秒到两个流的超过50毫秒。我在一个带有超线程的6核haswell-e上运行</e
浏览 0提问于2015-04-11得票数 0
1回答
如果我的kafka streams应用程序中有一个共享变量，并且是由处理代码中的多个线程更新的，那么如何处理呢？我是否必须确保共享变量线程的安全，或者卡夫卡流库是这样处理的呢？在文档中的某个地方，我读到在运行Kafka streams应用程序时，没有必要在线程之间进行协调。//update counter by multiple threads.如果这个代码是由来自同一个应用程序实例的<e
浏览 1提问于2018-02-01得票数 2
回答已采纳
3回答
这是对访问相同流的并发线程的某种类型的多线程预防吗？
在这一点上，当两个并发线程同时访问同一个流时，这会导致问题吗，或者两个线程都有自己的流指针吗？显然，需要等待，但希望它不会导致未检查的异常。
浏览 3提问于2011-11-07得票数 3
回答已采纳
1回答
也就是说，如果我有一个只使用单核的标准，并且我只使用了一个工作者，但我已经传递了-- ParDo -=n1- ParDo -2，那么数据流是否会运行两个并行的标准实例？
浏览 0提问于2017-05-24得票数 0
1回答
弹簧批并行微线程
、、、
我目前正在构建一个执行多个步骤的spring批处理应用程序。除了一个步骤之外，所有步骤都是简单的微线程(没有阅读器或编写器)，它们负责各种任务，如复制文件、发送请求、启动批处理(*.bat)文件等。在一个特定的步骤中，我希望启动X *.bat文件，它可能有最多的Y实例。
在一个例子中，假设我有10个*.bat文件，但我希望最大限度地具有5个并行运行。或者我应该只执行一次这个步骤并开发一个允许5(或Y)最大线程的“线程控制器”吗？假设必
浏览 1提问于2015-10-06得票数 0
"; closesocket(sock); };如果我要用互斥..。没有互斥就能做到这一点吗？
浏览 0提问于2017-09-16得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
