NSTimer 从不调用选择器函数 (Swift)

Question

保持冷静，这个问题很可能不是重复的。我已经尝试了堆栈溢出中的所有解决方案，但对我没有任何帮助。我有一个客户端线程，它不断地从另一台主机发送和接收 "keepalive" 字符串（ping）。如果它没有在 KeepAliveMax 中收到 "keepalive"，它会关闭流并说再见（理论上，但这仍在进行中）。现在我的问题是我使用 NSTimer 来调用 updateKeepAlive 函数，但它从未被调用过。我不明白为什么 :( 我也尝试过手动设置 NSTimer RunLoop，但它不起作用

以下是选择器函数应该被初始化并每秒调用的代码部分：

public class Client: NSObject, NSStreamDelegate  {

var serverAddress: CFString
let serverPort: UInt32 = 50000

private var inputStream: NSInputStream!
private var outputStream: NSOutputStream!
private var connecting:Bool
private var byteRead:Int
private var byteWrite:Int
private let keepAliveMax:Double = 5000
private var keepAliveTime:Double
private var connected:Bool
var timer: NSTimer?

init(ip:String) {
    serverAddress = ip
    connecting = false
    connected = false
    byteRead = 0
    byteWrite = 0
    keepAliveTime = 0

    super.init()

    let thread = NSThread(target:self, selector:#selector(connect), object:nil)

    thread.start()

    print("thread is started and now I can continue with other tasks..")

}

func connect() {

    connecting = true

    while connecting {
        print("connecting...")

        var readStream:  Unmanaged<CFReadStream>?
        var writeStream: Unmanaged<CFWriteStream>?

        CFStreamCreatePairWithSocketToHost(nil, self.serverAddress, self.serverPort, &readStream, &writeStream)

        // Documentation suggests readStream and writeStream can be assumed to
        // be non-nil. If you believe otherwise, you can test if either is nil
        // and implement whatever error-handling you wish.

        self.inputStream = readStream!.takeRetainedValue()
        self.outputStream = writeStream!.takeRetainedValue()

        self.inputStream.delegate = self
        self.outputStream.delegate = self

        self.inputStream.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
        self.outputStream.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)

        self.inputStream.open()
        self.outputStream.open()

        // send handshake

        byteWrite = writeLine("handshake")
        print("written: \(byteWrite) for handshake")


        // wait to receive handshake
        print("waintig for handshake...")


        if readLine() == "handshake" {
            connected = true

            print("Client: connection estabilished correctly")

            // close the waiting popup and start with SendBox...
            // in progress...

            // send keepAlive
            byteWrite = writeLine("keepalive")
            print("written: \(byteWrite) for keepalive")


            //======================== THIS NOT WORK PROPERLY ============================================================

            timer = NSTimer.scheduledTimerWithTimeInterval(1, target: self, selector: #selector(Client.updateKeepAlive), userInfo: nil, repeats: true)

            /*
             timer = NSTimer(timeInterval: 1, target: self, selector: #selector(Client.updateKeepAlive), userInfo: nil, repeats: true)

             NSRunLoop.currentRunLoop().addTimer(timer!, forMode: NSRunLoopCommonModes)
             */

            //============================================================================================================

            keepAliveTime = NSDate().timeIntervalSince1970 * 1000

            print("Client: Timer started")

            while self.inputStream.streamStatus != NSStreamStatus.Closed ||
                self.outputStream.streamStatus != NSStreamStatus.Closed
            {
                print("Client: under the while of keepAlive");

                if readLine() == "keepalive"
                {
                    keepAliveTime = NSDate().timeIntervalSince1970 * 1000
                    writeLine("keepalive")

                    print("Client: keepalive received");
                }
                else
                {
                    print("Client: not keepalive: ");
                    // close streams...... work in progress
                    break

                }

                sleep(1)
            }

        }
        else{
            print("wrong handshake")
        }


        print("closing streams..")
        connecting = false

        self.inputStream.close()
        self.outputStream.close()
        self.timer?.invalidate()
    }

}

下面是updateKeepAlive函数：

func updateKeepAlive(){

    print("in updateKeepalive function") // <---- NEVER PRINTED

    /*  in progress .....

    ........./*
}

Answer 1

在新线程开始时，没有输入源或计时器附加到运行循环。所以运行循环虽然不活跃。您可以在调用 scheduledTimerWithTimeInterval 后调用运行函数。

timer = NSTimer.scheduledTimerWithTimeInterval(1, target: self, selector: #selector(TimerTest.updateKeepAlive), userInfo: nil, repeats: true)
NSRunLoop.currentRunLoop().run()

NSTimer 从不调用选择器函数 (Swift)

NSTimer never call the selector function (Swift)

nstimer

ios

swift