concurrency 相关问题

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

EnvironmentKey 的 Swift 6 并发问题

我有一个相当简单的构造，在我尝试将 Swift 语言版本切换到 6.0 之前它一直运行良好：私有结构SomeHeightKey：EnvironmentKey { 静态变量默认值：CGFloat {

swift concurrency swift-concurrency swift6

回答 1 投票 0

CompletableFuture 如何知道任务何时完成？

CompletableFuture.supplyAsync(() -> otherService.get()) .thenAccept(值 -> { // 做某事 }); 后面是不是有无限循环来c...

java concurrency completable-future

回答 0 投票 0

Shedlock 仅适用于一个实例，不适用于多个实例

我想设置 Shedlock 来保护敏感进程，以便即使启动多个应用程序进程，也只有该进程的一个实例运行。在我的 pom.xml 中我想设置 Shedlock 来保护敏感进程，以便即使启动多个应用程序进程，也只有该进程的一个实例运行。在我的 pom.xml 中 <dependency> <groupId>net.javacrumbs.shedlock</groupId> <artifactId>shedlock-spring</artifactId> </dependency> <dependency> <groupId>net.javacrumbs.shedlock</groupId> <artifactId>shedlock-provider-jdbc-template</artifactId> </dependency> 我的数据库： CREATE TABLE shedlock( name VARCHAR(64) NOT NULL, lock_until TIMESTAMP NOT NULL, locked_at TIMESTAMP NOT NULL, locked_by VARCHAR(255) NOT NULL, PRIMARY KEY (name)); 我的配置： @Configuration @EnableScheduling public class ShedlockConfiguration { @Bean public LockProvider lockProvider(DataSource dataSource) { return new JdbcTemplateLockProvider( JdbcTemplateLockProvider.Configuration.builder() .withJdbcTemplate(new JdbcTemplate(dataSource)) .usingDbTime() .build() ); } } 我的日程： @Component public class SchedulerA { @Scheduled(initialDelayString = "${examples.scheduler.initial-delay:PT1S}", fixedDelayString = "${examples.scheduler.fixed-delay:PT10S}") @SchedulerLock(name = "example_scheduler", lockAtLeastFor = "${examples.scheduler.lock-at-least:PT5S}", lockAtMostFor = "${examples.scheduler.lock-at-most:PT30S}") public void schedule() { // Implementation not important } } 症状：如果我只启动一个具有多个 SchedulerA 类（如 SchedulerB、SchedulerC 等）的实例，这些类都是相同代码的副本，我可以看到 Shedlock 执行其操作，并且一次只允许一个 LOCAL 实例执行。但是，当我启动多个 Spring Boot 应用程序时，即使它们使用相同的数据库、相同的表、相同的调度程序名称，它们也会同时执行所有调度。我还注意到数据库表中没有任何条目，但调试日志也没有显示任何错误。问题：这是 Shedlock 的预期行为吗？我应该研究另一个解决方案还是我配置错误？您需要按照文档将@EnableSchedulerLock添加到您的配置类中：“为了启用计划锁定，请使用@EnableSchedulerLock注释” 您需要在 Spring Boot 应用程序启动的主类上添加带有强制参数 defaultLockAtMostFor 的 @EnableSchedulerLock 注释。它将防止同一 Spring Boot 应用程序的多个实例同时运行计划任务。我建议您进行以下操作： https://aahladkethineedi.medium.com/introduction-to-shedlock-in-spring-boot-80ce206475e5

spring concurrency scheduled-tasks scheduler shedlock

回答 3 投票 0

守护线程设置输入命令停止用户线程

我需要帮助解决我遇到的这个问题，所以如果有人遇到类似的问题，那将对我有很大帮助。该问题与 Java 中的并发编程有关。我有一个球课和一个测试...

java multithreading concurrency java-threads

回答 1 投票 0

“BatchBlock”在非贪婪模式下无法正常工作

当我使用贪婪模式时，一切都按预期进行。但是当我启用非贪婪模式时，会引发以下异常：未处理的异常。 System.InvalidOperationException：源已完成

c# .net concurrency tpl-dataflow

回答 1 投票 0

如何处理 Python Lambda 函数中创建 Secret 的 AWS 速率限制（每秒 50 个请求）？

我正在对 AWS Secrets 进行备份和恢复测试，其中我需要使用 Python Lambda 函数从备份 JSON 文件创建大约 1000 个密钥。 AWS 施加 50 个秘密的速率限制...

python amazon-web-services aws-lambda concurrency boto3

回答 1 投票 0

C++ 的 ConcurrentHashMap

是否有任何用于 C++ 实现的 ConcurrentHashMap 或类似的东西？我不明白为什么 C++ 中的多线程比 Java 难！

c++ multithreading concurrency

回答 5 投票 0

C++ 的并发集？

我正在寻找 C++ 中的无锁数据结构来替换以下内容： pthread_mutex_lock(plock); set.insert(元素); pthread_mutex_unlock(plock); 该集应该支持 .insert() 和 .size()

c++ concurrency lock-free concurrentskiplistmap libcds

回答 2 投票 0

如何使用Python Lambda批量创建AWS Secret？

我正在对 AWS Secrets 进行备份和恢复测试，我需要从备份 JSON 文件创建大约 1000 个密钥。我写了一个 Python Lambda 函数，但只部分成功...

python amazon-web-services aws-lambda concurrency boto3

回答 1 投票 0

Actor 符合具有异步函数要求的协议

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

swift concurrency swift6

回答 1 投票 0

我在无锁的SPSC中发现了一个奇怪的现象

我尝试使用无锁技术实现 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 的源代码。使用的软件包...