concurrency 相关问题

在计算机科学中，并发性是系统的属性，其中可以在重叠的时间段中执行多个计算。计算可以在同一芯片中的多个核上执行，在同一处理器上抢占时间共享线程，或者在物理上分离的处理器上执行。

我有一个具有同步功能要求的协议类不可发送{} 协议 P1 { func doSomething(_ nonSendable: NonSendable) 异步 } 当我使用演员遵守此协议时，同时...

swift concurrency swift6

回答 1 投票 0

我尝试使用无锁技术实现 SPSC，但遇到了奇怪的分段错误。代码如下： #包括 #包括 #包括 #包括我尝试使用无锁技术实现 SPSC，但遇到了奇怪的分段错误。代码如下： #include <iostream> #include <thread> #include <vector> #include <atomic> #define MATTER_NUM 10000 #define BUF_LEN 1024 uint64_t RingBuffer[BUF_LEN]; //uint32_t m_buffer[BUF_LEN]; std::atomic<uint64_t> head(0); std::atomic<uint64_t> tail(0); bool Push(const uint64_t &data) { uint64_t tmp_tail = tail.load(std::memory_order_relaxed); if ((tmp_tail + 1) % BUF_LEN == head.load(std::memory_order_acquire)) return false; RingBuffer[tmp_tail + 1] = data; tail.store((tmp_tail + 1) % BUF_LEN, std::memory_order_release); return true; } bool Pop(uint64_t &data) { static uint64_t cnt = 0; uint64_t tmp_head = head.load(std::memory_order_relaxed); if (tmp_head == tail.load(std::memory_order_acquire)) return false; data = RingBuffer[tmp_head]; head.store((tmp_head + 1) % BUF_LEN, std::memory_order_release); cnt = (tmp_head + 1) % BUF_LEN; return true; } int Producer() { for (int i = 0; i < MATTER_NUM; i++) { while (!Push(i)); } return 0; } int Consume() { for (int i = 0; i < MATTER_NUM; i++) { uint64_t data = -1; while (!Pop(data)); std::cout << data << std::endl; } return 0; } int main() { std::thread t1(Producer), t2(Consume); t1.join(); t2.join(); return 0; } 有一个奇怪的现象。当我取消第10行中的注释“uint32_t m_buffer[BUF_LEN]”时，代码神奇地正常运行！我不明白为什么会发生这种情况。内置 g++ (GCC) 7.5.0： g++ -std=c++11 -pthread main.cpp && ./a.out RingBuffer[tmp_tail + 1] = data; - 不需要 %BUF_LEN 吗？看来您偶尔会出现缓冲区溢出的情况。

c++ gcc concurrency thread-safety atomic

回答 1 投票 0

如何在 Swift 6 中表达流程管道的所有权释放

我有一个高度多线程的应用程序，可以在 Swift 5 中完美运行。我想切换到 Swift 6，并且我遇到了很少的错误，但仍然有这个错误，而且无法摆脱。代码是

swift concurrency

回答 1 投票 0

优化从支付网关获取交易状态的重试间隔

我有一个系统，其中交易最初在关系数据库中标记为“待处理”，如果支付网关未立即成功支付交易，我需要获取

concurrency queue rdbms system-design high-level-architecture

回答 1 投票 0

在 React 应用程序中的多个输入文件上运行 ffmpeg (WASM/NodeJS)

我最近按照 Fireship.io 的教程制作了一个 React 应用程序，该应用程序使用户能够输入视频文件并将其转换为 gif。这是 GitHub Repo 的源代码。使用的软件包...