iOS套接字输入流阻止UI，但未在主线程上安排

Question

当我的应用程序通过网络输入流接收数据时，在主线程上调用相应的streamDelegate。当接收大量数据时，UI阻塞值得注意。我试图从a中解雇所有相应的函数

DispatchQueue.global(qos: .whatever).sync()

但是虽然

inputStream.schedule(in: .current,forMode: .commonModes)

在该队列中调用，还是在Main？上调用了streamDelegate？

从我读到和理解到现在为止，.sync无论如何都不会帮助我，因为它仍然会阻止UI，因为它会等待完成，然后才能将控件返回给UI。所以我尝试使用.async。当所有流内容正在处理异步线程时，outputStream工作正常，但inputStreams的streamDelegate不会触发。我没有收到回复。

我究竟做错了什么？

class AppDelegate {
  let mSocketClass = SocketClass()
  func application(_:){
    DispatchQueue.global(qos: .utility).async(){
      mSocketClass.setupNetworkCommunication()
      mSocketClass.sendStuff()
    }
  } 
}

.

class SocketClass:NSObject {
  var mInputStream: InputStream!
  var mOutputStream: OutputStream!

  func setupNetworkCommunication(){
    var readStream: Unmanaged<CFReadStream>?
    var writeStream: Unmanaged<CFWriteStream>?
    CFStreamCreatePairWithSocketToHost(kCFAllocatorDefault, "example.com" as CFString, 1234, &readStream, &writeStream)
    mInputStream = readStream!.takeRetainedValue()
    mOutputStream = writeStream!.takeRetainedValue()
    mInputStream.schedule(in: .current, forMode: .commonModes) //happens on thread other than Main
    mOutputStream.schedule(in: .current, forMode: .commonModes)
    mInputStream.open()
    mOutputStream.open()
    mInputStream.delegate = self
  }

  func sendStuff(){
    if mOutputStream.hasSpaceAvailable {
      mOutputStream.write(...)
    }
  }
}

extension SocketClass:StreamDelegate{
  func stream(_ aStream: Stream, handle eventCode: Stream.Event) {
    switch eventCode {
      case Stream.Event.hasBytesAvailable:
        (aStream as! InputStream).read(...) //happens on Main
    }
  }
}

顺便说一句：我不喜欢使用框架的解决方案。在我看来，解决方案是改变我不理解的单行。

谢谢！

Answer 1

代码几乎没问题，但是你需要在该线程上启动一个运行循环。

所以看起来应该是这样的：

DispatchQueue.global(qos: .utility).async(){
    self.mSocketClass.setupNetworkCommunication()
    RunLoop.current.run()
}

请注意：

• RunLoop.current.run()永远不会回来。应该是您设置的最后一行。
• 然后在后台线程上接收数据。如果要在接收数据后更新用户界面，则必须使用DispatchQueue.main.async() { /* UI updates */ }

让我知道它对你有用。