我正在尝试使用@propertyWrapper 创建一个线程安全的结构,但是当我设置一个值时,我在操场上遇到了这样的错误。错误发生,只有当我改变async
to sync
,但我只需要有async
功能
@propertyWrapper
struct SafeThread<Value>{
private let queue = DispatchQueue(label: "sellQueue",attributes:.concurrent )
private var value: Value
init (wrappedValue: Value){
self.value = wrappedValue;
}
var wrappedValue :Value {
get { queue.sync { value } }
set { queue.async(flags: .barrier) { self.value = newValue } } // there an error
}
}
和我想使用它的类:
class Safe{
@SafeThread var foo = 0;
func threadSafetyExperiment() {
DispatchQueue.global().sync {
DispatchQueue.concurrentPerform(iterations: 1_000) { _ in
self.foo += 1
}
print(self.foo)
}
}
}