concurrency

我有一个程序可以处理并行运行的各种任务。单个任务充当各种管理器，确保在运行下一个任务之前满足某些条件。但是，我发现有时某个任务会长时间处于 WaitingToRun 状态。下面是代码： mIsDisposed = false; mTasks = new BlockingCollection<TaskWrapper>(new ConcurrentQueue<TaskWr... »

这是我在 Stack Overflow 上的第一个问题，所以如果我做了一些愚蠢的事情或遗漏了什么，我深表歉意。 我正在尝试一次向多个 api 端点发出异步 aiohttp GET 请求以检查这些页面的状态：结果应该是表单的三倍 (url, True, "200") 在有效链接的情况下和 (url, False，response_status）在“有问题的链接”的情况下。这是每次调用的原子函数：... »

我有一个被许多线程不断调用的方法，它在数据结构中查找数据。 当需要更新该数据结构时，我需要阻止所有尝试查找的线程，直到更新完成。 我可以使用带有 X 许可的信号量，并让 update 方法在执行更新之前获取所有 X 许可，然后再次释放它们 - 但现在 X 还用于将我的查找方法限制为 X 个同时调用的次要目的，我不想。 我还有哪些其他选项可以阻止对更新方法的调用而不限制它的同时执行？ ... »

直接来自ConcurrentHashMap javadocs： 更新操作之间允许的并发由 可选的 concurrencyLevel 构造函数参数（默认 16），即 用作内部尺寸调整的提示。该表在内部 分区以尝试允许指定数量的并发 无争用更新。因为在哈希表中的放置是 本质上是随机的，实际并发会有所不同。 当他们说：“用作内部调整大小的提示”时，我不明白这一点。大小不应... »

我正在创建一个这样的串行后台队列： @property (nonatomic, strong) dispatch_queue_t assetCreationQueue; // in init... _assetCreationQueue = dispatch_queue_create("com.mycompany.assetCreationQueue", DISPATCH_QUEUE_SERI... »

看看这个人为的例子： package main import "fmt" func printElo() { fmt.Printf("Elo\n") } func printHello() { fmt.Printf("Hello\n") } func main() { fmt.Printf("This will print.") i := 0 fo... »

func main() { jobs := []Job{job1, job2, job3} numOfJobs := len(jobs) resultsChan := make(chan *Result, numOfJobs) jobChan := make(chan *job, numOfJobs) go consume(numOfJobs, jobCha... »

我在使用线程在 python 中编写基准代码时遇到问题。我能够让我的线程工作，但我不能让我的对象返回一个值。我想获取这些值并将它们添加到列表中，以便计算翻牌。 创建类来执行线程 class myThread(threading.Thread): def calculation(self): n=0 start=time.time() ... »

我有一个在多个线程之间共享的字符串列表。每个线程必须： 访问列表（例如通过 getter 方法）； 获取列表的大小； 在零和list.size()之间选择一个随机数n； 从列表中提取偏移 n 处的元素； 从列表中删除提取的元素； “保存”列表，以便其他线程始终查看更新的列表 由于存在对可变共享对象（列表）的并发访问，我需要以线程安全的方式进行编码。每个线程都必须将列表大小减一，因此每个其他线... »

我正在帮助修饰一个应用程序，它充满了并发问题。我正在尝试解决它们，并遇到了使用 DataTables 的部分。 数据表本身是静态的，在多个线程之间共享。 我知道使用 dt.Select("...") 本身需要一个 lock 语句，否则在向数据表添加/删除行时会出现问题。但是，当该调用返回时，您将拥有一个 DataRow 对象数组。 如果我要更新它们，我显然会锁定这些行，但如果我只是阅读它们... »

我在做一些实际上应该很简单的事情时有点挣扎。我有一个函数可以进行一些长时间的计算，为了简化它，如下所示： import time def compute_stuff(number): time.sleep(10) return [number*2, number*4] 我想并行运行此函数的两个实例并将它们的结果收集到一个数组中。我读过一些关于 Twisted reacto... »

我有一个进程产生了几个子进程。它们都共享一个信号量。 在我的主程序中。 sem_t *sharedSem = sem_open(SHAREDSEM, O_CREAT, 0600, 4); // Initial 1 在我的子程序中。 > sem_t * serverSem = sem_open(SHAREDSEM, 0); sem_wait(serverSem); pri... »

在 .NET 4 中是 possible to enable 并发 GC。 Q1 它如何与并行计算一起工作：Parallel、Task、PLINQ 等？Q2 作为软件开发人员，我应该注意什么什么时候使用并发 GC？... »

假设我有两列 CategoryId 和 SubcategoryId。对于每个 CategoryId，SubcategoryId 从 1 开始。插入新的子类别时，我需要为给定的 CategoryId 计算 MAX(SubcategoryId)+1。 下列说法正确吗？ BEGIN TRANSACTION DECLARE @NextId bigint; SELECT @NextId = ISNULL... »

我正在尝试创建两个并发运行的线程我如何测试它们是否同时运行它在当前线程结束后线程正在运行的输出中接缝？这是正在发生还是您正在同时运行？ public class Start { public static void main(String[] args) { new ThreadOne(); Thread t = Thread.currentThread(); // Stati... »

我正在编写一个小通知服务器来将数据推送到客户端。基本架构看起来像这样（精简伪代码）： acceptConnections sock = forever $ do connection <- accept sock forkIO (handleConnection connection) handleConnection connection = do connec... »

我正在寻找一种允许并发文件对象查找的方法。 作为文件搜索谨慎的测试用例： #!/usr/bin/env python2 import time, random, os s = 'The quick brown fox jumps over the lazy dog' # create some file, just for testing f = open('file.txt', 'w') ... »

我使用 node.js sqlite3 来操作数据。我使用这些代码将数据插入数据库并获取插入的 id： db.run("INSERT INTO myTable (name) VALUES ('test')"); db.get("SELECT last_insert_rowid() as id", function (err, row) { console.log('Last inser... »

使动态数组线程安全和并发是什么意思？ 例如，std::vector。 可能需要在同一位置插入两个线程。无需同步，因为它将根据线程调度完成。 一个线程擦除而另一个线程访问相同的元素？我认为这不是数据结构问题，而是使用问题。 那么有什么需要在std::vector 上完成以使其成为线程安全和并发的，还是默认情况下是线程安全和并发的？ ... »

我在 Visual Studio 2010 中使用简单的并发运行时 task_group 来运行单个工作线程，以将工作与 GUI 线程分开。 但是我的一位同事告诉我，我使用 CR 是错误的：它是为并行处理具有小上下文的轻量级任务而设计的，而不是用于从 GUI 中分离出庞大且依赖 I/O 的线程。他说他从文档中获取了这个，但没有提供任何具体的链接。 那么，Microsoft Concurrenc... »