如題,今天的博客我們就來記錄一下iOS開發中使用MachPort來實現線程間的通信,然后使用該知識點來轉發子線程中所發出的Notification。簡單的說,MachPort的工作方式其實是將NSMachPort的對象添加到一個線程所對應的RunLoop中,並給NSMachPort對象設置相應的代理。在其他線程中調用該MachPort對象發消息時會在MachPort所關聯的線程中執行相關的代理方法。
下方內容我們先來看一下MachPort的工作方式,然后再看一下在子線程中發Notification的效果,最后我們在通過MachPort來講子線程中的發出的通知轉發到主線程中進行處理。
一、MachPort的使用方式
接下來我們就通過一個小的示例來簡單的看一下MachPort的使用方式。首先我們聲明了一個NSMachPort的成員屬性handelEventMachPort,該變量實例化后指定其NSMachPortDelegate的對象為當前類。然后將handelEventMachPort添加到主線程中,具體代碼如下所示。
搞定NSMachPort對象后,接下來我們要在當前VC實現NSMachPortDelegate代理中相關的方法,如下所示。當在其他線程中調用上述的MachPort對象發送消息時,會在主線程中執行下方的代理方法。在該方法中我們打印了該方法執行時所在的線程,具體代碼如下所示:
實例化完MachPort對象以及實現其相關的代理方法后,接下來要做的事情就是開辟一個新的線程,然后在這個新的線程中調用handelEventMachPort對象,往主線程所對應的RunLoop中發送消息。
代碼實現完畢后,接下來就該看一下運行效果了。下方就是上述代碼示例所運行的結果。從結果中我們不難看出,點擊按鈕時,會開啟一個新的子線程,我們將這個開啟的子線程命名為“MySubThread”。在這個子線程中我們調用了與主線程關聯的MachPort對象發送消息。然后在主線程中執行該MachPort對象的相關回調方法,每次點擊按鈕的輸出如下所示:
二、子線程中Notification的發送
該部分算是為下一部分做鋪墊的,本部分的代碼示例比較簡單。做的事情主要是在主線程中注冊一個觀察者,然后在開啟的子線程中發送通知,我們來看一下處理該通知的方法所處的線程。
下方就是本部分的核心代碼,代碼比較簡單。首先我們打印出注冊觀察者的線程,然后往通知中心添加觀察者。緊接着我們就創建一個子線程,然后對子線程的信息進行打印並獲取通知中心單例發送通知。
然后在收到通知事件所執行的方法中,我們要做的事情就是對執行該方法的線程進行打印。具體代碼如下所示:
實現完上述代碼后,下方是上述代碼的運行結果。從結果中我們不難發現,雖然是在主線程中添加的觀察者,但是如果在子線程中發出通知,那么就在該子線程中處理通知所關聯的方法,具體效果如下所示:
三、將子線程發出的通知通過MachPort轉發到主線程中進行處理
接下來所做的事情就是將第一部分和第二部分的內容進行整合。也就是將子線程發出的通知通過MachPort轉發到主線程中進行處理。下方的代碼示例我們參考了Apple Developer中的相關示例(鏈接請戳我)。當然了,對其官方示例我們做了一些修改,目的是為了更易於理解。
首先還是得實現NSMachPortDelegate相關協議中的方法,下方代碼段中的notificationQueue用來純粹子線程發出的所有通知,mainThread則是用來儲存主線程了,lock則是對通知隊列加鎖,避免多個線程同時操作該隊列所出現的數據不一致問題。mackPort則是用於向期望線程發送信號的通信端口。
下方的代碼段則是對上述字段的賦值。
接着我們在viewDidLoad方法中打印了注冊通知的線程,當然此處是主線程了。然后在子線程中異步的發送一條通知,具體代碼如下所示:
下方就是收到通知后所執行的方法,在該方法中,我們看到做了一個判斷。如果該方法是在我們預期的主線程中被執行的話,那么我們就執行收到通知后所要執行的任務。如果不是我們預期的主線程的話,接下來走的就是通過MachPort來轉發到主線程了。
在轉發通知前要把當前方法所接收到的notification入隊列暫存,等轉發后,在MachPort的相關代理方法中取出相關的通知並做相關處理。
下方代碼段就是處理MachPort所轉發過來的消息。在該方法中取出了隊列中暫存的相關通知並進行了相關處理。代碼如下所示。
下方是具體的運行結果:
本篇博客所涉及demo在github上的分享地址如下: