concurrent-queue

2热度

1回答

我正在读this question，并注意到OP正在迭代列表以将项目排入ConcurrentQueue。 ConcurrentQueue<TaskClass> cq = new ConcurrentQueue<TaskClass>(); for (int x = 0; x < TaskList.Count; x++) cq.Enqueue(TaskList[x]); 这是必要的吗？

1热度

2回答

如何多线程队列处理

C++容器是supposed to be thread-safe by default。我必须用queue错误地多线程，因为这样的代码： #include <thread> using std::thread; #include <iostream> using std::cout; using std::endl; #include <queue> using std::queue;

0热度

1回答

多个类实例引发同一事件

我无法弄清楚我的C＃代码出了什么问题。我在学习如何在System.Collections.Concurrent命名空间中使用ConcurrentQueue类。为了做到这一点，我在不同的线程中创建了2个相同类的实例，并向构造函数传递了一个不同的Listbox控件。我期待EventGenerator的每个类实例以随机间隔引发事件，更新随机生成的数字传递的Listbox，并将该数字添加到也传递给构

1热度

1回答

Parallel.For通过使用ConcurrentQueue列表中的项目 - 这个工作吗？

我有一个List<TaskClass> TaskList项目，我们可以使用并行循环迭代。由于TaskClass使用自己的CompareTo(object obj)方法实现IComparable，因此列表中的项目按特定顺序排序。因此，我们需要按顺序执行的项目。请注意，它们不必按顺序完成，只需按顺序开始即可。因此TaskList [0]应该先启动;然后TaskList [1]，TaskList

-1热度

1回答

并发队列离队

我使用并发队列，并通过创建Action委托 Action action =() => { SubscriptionResponseModel subsModel; while (concurrentQueue.TryTake(out subsModel)) { MakeTransactionAndAddIntoQueue(sub

0热度

2回答

使用全局并发队列从两个不同线程中变换阵列时不会发生崩溃

在下面的代码中，我们有一个可变数组，它由两个并发队列进行变异。由于并发队列不是线程安全的，因此这段代码最好应该崩溃，但是这个代码不会发生任何异常或崩溃。请帮助我理解这种行为。任何帮助将不胜感激:-) @interface ViewController() @property(nonatomic, strong) NSMutableArray *arr; @end

-1热度

1回答

循环通过ConcurrentQueue <T>无限期地利用基于定时器/秒表事件

在我CheckQueue()方法（通过调用AppQ.Connect(Time)）和TryDequeue每个项目关闭它我想要做的就是不断地从队列中读到的东西。经过一段时间（也许一分钟左右）后，我想返回到队列 - 再次连接，检查它是否有一些元素（AppQ.Count），阅读它们（通过TryDequeue()），并无限期地执行此过程。这是一个应用程序，它将成为一个Windows服务（目前是用于测试目的

2热度

2回答

ConcurrentQueue和Parallel.ForEach

我有一个ConcurrentQueue和一个我需要获取源代码的URL列表。当以ConcurrentQueue对象作为输入参数使用Parallel.ForEach时，Pop方法不会工作（应该返回一个字符串）。我正在使用MaxDegreeOfParallelism并行设置为四。我真的需要阻止并发线程的数量。是否使用并行冗余的队列？在此先感谢。 // On the main class var i

1热度

1回答

从队列读取和写入

我正在将一组〜300位图保存在并发队列中。我正在做这个over-tcp视频流媒体节目。如果服务器速度变慢，我将接收到的位图保存在此队列中（缓冲）。我创建了一个单独的项目来测试，但我遇到了一些问题。虽然写入线程正在工作（写入队列），但图片框显示队列中的图像，但它似乎跳过了其中的很多图像（就像它正在读取刚添加到“列表”中的图片）通过写入线程而不是FIFO行为）。当写入线程完成图片框时，虽然我从队列中

0热度

1回答

从ConcurrentQueue插入多行到SQL Server表中

我有一个c＃应用程序正在从一个数据库中取数据，进行必要的转换，并将数据插入到另一个数据库的表中。我通过将我的源数据插入到队列中，然后处理队列以将数据插入到目标表中来完成此操作。我有两个独立的线程来读取源数据并写入目标数据。阅读线程的运行速度比写入线程快得多，所以我的队列填满很快。正如您在阅读线程中所看到的，我使用SqlCommand.ExecuteReader（）来读取数据。然后我循环遍历队列并