concurrency 相关问题

// @MainActor is not an option here ! class Foo : NSObject { private var operationQueue: OperationQueue? // some other mutable properties, no way to make Foo conform to Sendable // this must stay async because I have to wait for a file coordinator, code not shown for brevity func load() async -> String { return "Text" } } extension Foo: NSFilePresenter { nonisolated var presentedItemURL: URL? { return URL(string: "Bla") } nonisolated var presentedItemOperationQueue: OperationQueue { if operationQueue == nil { operationQueue = OperationQueue() } return operationQueue! // unsafe, but not the problem here } nonisolated func presentedItemDidMove(to newURL: URL) { // Question: How to load() safely ? load() // ERROR: 'async' call in a function that does not support concurrency Task { // ERROR: Passing closure as a 'sending' parameter risks causing data races between code in the current task and concurrent execution of the closure await load() } Task { @MainActor in // ERROR: Task or actor isolated value cannot be sent await load() } } }

swift async-await concurrency isolation swift6

回答 1 投票 0

AtomicInteger和Integer之间有任何性能差异吗？

和

java concurrency atomicinteger

回答 4 投票 0

在GO中有效消费Kafka消息的最佳并发模式是什么？我在GO中研究Kafka消费者，目前使用一个简单的循环来获取和处理消息。我将使用go commume（）称此功能同时运行它。但是，我不确定是否...

func Consume(ctx context.Context, k *kafka.Reader, handler IMessageHandler) { for { msg, err := k.FetchMessage(ctx) if err != nil { log.Error("Failed to fetch message", "error", err) return } err = handler.Handle(ctx, msg) if err != nil { log.Error("Failed to handle message", "error", err) continue } commitWithRetry(ctx, k, msg) }

go apache-kafka design-patterns concurrency goroutine

回答 1 投票 0

我目前正在使用管理设备连接和设备固件状态的SDK。它对这两个功能都使用相同的代表。您需要在模拟背景中模拟固件更新时跟踪设备状态。

swift xcode async-await concurrency asyncstream

回答 0 投票 0

旋转异步功能可与任务一起函数。我现在正在学习Swift并发，我已经编写了一些代码来尝试一下。我期望早些时候“下载”具有更大ID的“照片”。 func downloadphoto（id：...

swift concurrency

回答 1 投票 0

ConcurrentDictionary 陷阱 - GetOrAdd 和 AddOrUpdate 中的委托工厂是否同步？

ConcurrentDictionary 的文档没有明确说明，所以我想我们不能期望委托 valueFactory 和 updateValueFactory 的执行同步（来自 GetOrAdd() 和

c# .net multithreading concurrency thread-safety

回答 2 投票 0

如何在遗留函数内改变声明为超大的 var？

我有一个在遗留函数之外初始化的 var （我无法更改）。它在 Swift 6 中给了我一个警告。这是一个最小的代码示例（除了显示编译之外，它绝对没有任何意义......

swift async-await concurrency swift6

回答 1 投票 0

STD::atomic

std::atomic<int> unique_ids; void foo() { int i = unique_ids.fetch_add(1, std::memory_order_relaxed); std::cout<<i; } int main(int argc, char* argv[]) { std::vector<std::thread> threads; for (int i = 0; i < 9; ++i) { threads.emplace_back(foo); } for (int i = 0; i < 9; ++i) { threads[i].join(); } std::cout << std::endl; return 0; } 我的目标是使用原子来为并发计划生成独特的ID，但我不在乎这些订单。 < 对于上述代码，我的理解是，尽管不能保证其订单，但FOO中的输出值应该有所不同。 I测试了上述代码一百次，所有结果都是我所期望的。我是原子 /记忆顺序的初学者，谁能帮助我澄清自己的理解？提前感谢。 Aimin P.S。我想指出的是，这个问题与一个C++，std :: atomic，什么是std :: memory_order和如何使用它们的问题不同有关原子和记忆顺序的解释的问题。这是放松记忆订购的合法使用。您只需要对其他对同一原子的访问就可以是原子。每个原子操作都具有该特征，无论记忆排序如何，或者根本不是原子。内存顺序的规范仅与此线程之前和/或之后完成此线程的其他读取/写入有关，然后通过其他线程读取该线程（又称线程的顺序，请参见副作用另一个线程至少两个访问）。由于这里只涉及一个单个内存访问（尽管读取模式 - 访问），记忆顺序是无关紧要的，放松效果会很好。但是，读取 - 修改工艺的操作是特别的。这些始终具有全球总顺序，独立于指定的内存顺序；这意味着每个线程都会以相同的顺序看到副作用（原子的值）；即使他们只阅读值，也没有人会首先看到3，然后是2。

c++ concurrency atomic memory-barriers

回答 1 投票 0

在线程中将多个API添加在一起

ios concurrency

回答 2 投票 0

sync.WaitGroup 相对于 Channels 有什么优势？

我正在开发一个并发 Go 库，我偶然发现了 goroutine 之间两种不同的同步模式，其结果相似：等待组包主进口（ “fmt”...

go concurrency channel

回答 7 投票 0

如何在View成员函数中使用委托？

我正在重组我的项目，我反复遇到以下问题：在我的视图类中，我有从例如执行的函数按钮。其中一些功能需要使用系统

swift swiftui design-patterns concurrency swift6

回答 1 投票 0

concurrency 相关问题

最新问题