??? ?? ACE_WFMO_Reactor允許多個線程并發的調用handle_events(),這個能力的增加使得它的設計變的復雜,并且引入了一些同基于select的反應器不同的地方.不同點如下:
- 注冊改變的協調.已注冊句柄集合的每一個改變,將會影響到所有執行事件循環的線程.在沒有同步的情況下允許這些改變的發生,會導致丟失事件,或不正確,不合法的句柄被分發.為了在多線程的情況下,正確的處理注冊發生改變的情況,ACE_WFMO_Reactor維持了三個句柄信息集合對象.
- 用作事件偵查和分發的當前句柄
- 新句柄, 除了當前句柄集合,新句柄也在等待
- 掛起句柄,是當前句柄中掛起的句柄
當需要改變已注冊的句柄時,(例如:注冊,移除,掛起和恢復一個事件處理器),要記住句柄,事件處理器,事件類型信息,和相關信息的記錄.下一個完成handle_events的線程會注意到這個改變,獲取reactor的鎖,等待所有其他正在運行handle_events的線程完成.為了能讓這些線程及時的完成,等待的線程發送一個內部事件,該內部事件是分發句柄集合的一部分.喚醒所有阻塞在WaitForMultipleObjects的線程.這個時候,所有的事件處理線程將會阻塞在等待變化的發生.當原始的線程完成必要的信息和句柄改變后,釋放reactor的鎖.所有的事件處理線程重新開始在更新后的句柄集合上進行等待,分離和分發.
- 推遲事件處理器的清除.ACE_WFMO_Reactor注冊改變的延遲引入了一些與基于select()的反應器的不同之處.當hanle_*()方法返回-1或者ACE_Reactor::remove_handler()被事件處理器調用時,它推遲事件處理器的移除和handle_close()鉤子函數的回調,直到上面說講的注冊改變發生.所以一個應用在請求ACE_WFMO_Reactor移除一個事件處理器之后,不能立即刪除該事件處理器,否則reator后來調用的handle_close()方法會分發一個無效的指針.