我有一个现有的防抖实用程序,使用DispatchQueue
。它接受一个闭包并在达到时间阈值之前执行它。可以像这样使用:
let limiter = Debouncer(limit: 5)
var value = ""
func sendToServer() {
limiter.execute {
print("\(Date.now.timeIntervalSince1970): Fire! \(value)")
}
}
value.append("h")
sendToServer() // Waits until 5 seconds
value.append("e")
sendToServer() // Waits until 5 seconds
value.append("l")
sendToServer() // Waits until 5 seconds
value.append("l")
sendToServer() // Waits until 5 seconds
value.append("o")
sendToServer() // Waits until 5 seconds
print("\(Date.now.timeIntervalSince1970): Last operation called")
// 1635691696.482115: Last operation called
// 1635691701.859087: Fire! hello
请注意,它不会多次调用
Fire!
,而只是在最后一次调用后的5秒钟内使用最后一个任务的值。 Debouncer
实例被配置为将队列中的最后一个任务保留5秒钟,无论调用多少次。 闭包被传递到 execute(block:)
方法中:final class Debouncer {
private let limit: TimeInterval
private let queue: DispatchQueue
private var workItem: DispatchWorkItem?
private let syncQueue = DispatchQueue(label: "Debouncer", attributes: [])
init(limit: TimeInterval, queue: DispatchQueue = .main) {
self.limit = limit
self.queue = queue
}
@objc func execute(block: @escaping () -> Void) {
syncQueue.async { [weak self] in
if let workItem = self?.workItem {
workItem.cancel()
self?.workItem = nil
}
guard let queue = self?.queue, let limit = self?.limit else { return }
let workItem = DispatchWorkItem(block: block)
queue.asyncAfter(deadline: .now() + limit, execute: workItem)
self?.workItem = workItem
}
}
}
我该如何将这个转换为并发操作,以便可以像下面这样调用:
let limit = Debouncer(limit: 5)
func sendToServer() {
await limiter.waitUntilFinished
print("\(Date.now.timeIntervalSince1970): Fire! \(value)")
}
sendToServer()
sendToServer()
sendToServer()
然而,这不会去抖动任务,而是将它们暂停,直到下一个被调用。相反,应该取消前一个任务,并保留当前任务,直到去抖时间结束。是否可以使用Swift Concurrency来实现这一点,或者有更好的方法来做到这一点?