如何跟踪提交的任务？

如何解决如何跟踪提交的任务？

用例：当我的API服务收到HTTP请求时，它将转换为延迟作业并将其提交给dask调度程序，但不想阻止它以至于占用一个线程/进程在服务器上。它还希望获得工作进度的最新信息。我在集群环境中这样做，所以有多个API服务容器。

方法

1. 使用 import UIKit import Foundation import CoreBluetooth class ItemsViewController: UITableViewController,CBCentralManagerDelegate,CBPeripheralDelegate { var manager: CBCentralManager! let scanningDelay = 1.0 var items = [String: [String: Any]]() override func viewWillAppear(_ animated: Bool) { super.viewWillAppear(animated) manager = CBCentralManager(delegate: self,queue: nil) } override func tableView(_ tableView: UITableView,numberOfRowsInSection section: Int) -> Int { return self.items.keys.count } override func tableView(_ tableView: UITableView,cellForRowAt indexPath: IndexPath) -> UITableViewCell { let cell = tableView.dequeueReusableCell(withIdentifier: "ItemCell",for: indexPath) // Configure the cell... if let item = itemForIndexPath(indexPath){ cell.textLabel?.text = item["name"] as? String if let rssi = item["rssi"] as? Int { cell.detailTextLabel?.text = "\(rssi.description) dBm" } else { cell.detailTextLabel?.text = "" } } return cell } func itemForIndexPath(_ indexPath: IndexPath) -> [String: Any]?{ if indexPath.row > items.keys.count{ return nil } return Array(items.values)[indexPath.row] } // MARK: - CBCentralManagerDelegate func centralManagerDidUpdateState(_ central: CBCentralManager){ if central.state == .poweredOn{ manager.scanForPeripherals(withServices: nil,options: nil) } } func centralManager(_ central: CBCentralManager,didDiscover peripheral: CBPeripheral,advertisementData: [String : Any],rssi RSSI: NSNumber){ didReadPeripheral(peripheral,rssi: RSSI) } func peripheral(_ peripheral: CBPeripheral,didReadRSSI RSSI: NSNumber,error: Error?) { didReadPeripheral(peripheral,rssi: RSSI) delay(scanningDelay){ peripheral.readRSSI() } } func didReadPeripheral(_ peripheral: CBPeripheral,rssi: NSNumber){ if let name = peripheral.name{ items[name] = [ "name":name,"rssi":rssi ] } tableView.reloadData() } func centralManager(_ central: CBCentralManager,didConnect peripheral: CBPeripheral){ peripheral.readRSSI() } } func delay(_ delay:Double,closure:@escaping ()->()) { DispatchQueue.main.asyncAfter( deadline: DispatchTime.now() + Double(Int64(delay * Double(NSEC_PER_SEC))) / Double(NSEC_PER_SEC),execute: closure) } 。但是，这会阻碍工作，尤其是对于长期运行的工作来说是个问题。
2. 使用client.submit获取未来并查询未来，如Why do my Dask Futures get stuck in 'pending' and never finish?中所述。在该特定线程中，建议使用字典来跟踪返回的将来对象。但是，由于dict是容器的本地容器，因此无法扩展到集群环境。

有什么建议吗？