FBKVOController - 面试聊到KVO如何有效的怒怼面试官!

这里请先思考以下问题：

• 属性observer为何使用weak，它和哪个对象之间会导致循环引用问题，是如何导致循环引用问题的？
• 为何不使用字典来保存被监听对象和被监听属性集合之间的关系？
• NSDictionary的局限性有哪些？NSMapTable相对字典，有哪些优点？
• 互斥锁是为了保证哪些数据的线程安全？

带着这些问题我们来看FBKVOController内部是如何实现监听的，这里我们只看带Block回调的一个监听方法，其他几个方法和这个方法内部实现是相同的。下面的方法内部做了如下工作：

• 1.传入的参数keyPath，block为空时，程序闪退，同时报出误提示；
• 2.对传入参数为空的判读；
• 3.利用传入的参数创建_FBKVOInfo对象；
• 4.调用内部私有方法实现注册监听；

• 1.首先判断hash值是否相等，若相等则进行第2步；若不等，则直接判断不等；hash值是对象判等的必要非充分条件；（即没它一定不行，有它不一定行）
• 2.在hash值相等的情况下，再进行对象判等, 作为判等的结果

@interface _FBKVOSharedController : NSObject

// 单例初始化方法
+ (instancetype)sharedController;

// 监听object的属性
- (void)observe:(id)object info:(nullable _FBKVOInfo *)info;

//移除对object中属性的监听
- (void)unobserve:(id)object info:(nullable _FBKVOInfo *)info;

// 移除对object中多个属性的监听
- (void)unobserve:(id)object infos:(nullable NSSet *)infos;

@end

{
//存放被监听属性的信息对象

  NSHashTable<_FBKVOInfo *> *_infos;
//互斥锁

  pthread_mutex_t _mutex;

}

//添加监听
- (void)observe:(id)object info:(nullable _FBKVOInfo *)info

{
//被监听的属性信息_FBKVOInfo对象为空时，直接返回
if (nil == info) {
return;

  }

// 加锁，防止多线程访问时，出现数据竞争
pthread_mutex_lock(&_mutex);

// 将被监听的属性信息info对象添加到_infos中，_infos对成员变量info是弱引用

  [_infos addObject:info];   

//添加完成之后，解锁，其他线程可以访问
pthread_mutex_unlock(&_mutex);

// 添加监听

  [object addObserver:self forKeyPath:info->_keyPath options:info->_options context:(void *)info];

//修改监听状态
if (info->_state == _FBKVOInfoStateInitial) {


    info->_state = _FBKVOInfoStateObserving;


  } else if (info->_state == _FBKVOInfoStateNotObserving) {

//不再监听时安全移除观察者
// this could happen when `NSKeyValueObservingOptionInitial` is one of the NSKeyValueObservingOptions,
// and the observer is unregistered within the callback block.
// at this time the object has been registered as an observer (in Foundation KVO),
// so we can safely unobserve it.

    [object removeObserver:self forKeyPath:info->_keyPath context:(void *)info];

  }

}

//被监听属性更改时的回调
- (void)observeValueForKeyPath:(nullable NSString *)keyPath

                      ofObject:(nullable id)object

                        change:(nullable NSDictionary<NSString *, id> *)change

                       context:(nullable void *)context

{
NSAssert(context, @"missing context keyPath:%@ object:%@ change:%@", keyPath, object, change);


  _FBKVOInfo *info;

  {
pthread_mutex_lock(&_mutex);
//确定_infos是否包含给定的对象context，若存在返回该对象，否则返回nil;
//所使用的相等性比较取决于所选择的选项
//例如，使用NSPointerFunctionsObjectPersonality选项将使用isEqual：方法来判断相等。

    info = [_infos member:(__bridge id)context];
pthread_mutex_unlock(&_mutex);

  }

//通过上下文参数context传过来的被监听的_FBKVOInfo对象，已经存在_infos中
if (nil != info) {

//_FBKVOSharedController对象强引用FBKVOController对象，防止被提前释放
//因为在_FBKVOInfo中，对FBKVOController对象是弱引用

    FBKVOController *controller = info->_controller;
if (nil != controller) {

//强引用观察者，在FBKVOController中，FBKVOController对象弱引用观察者observer，防止在使用时已经被释放

      id observer = controller.observer;
if (nil != observer) {

//使用自定义block回传监听结果
if (info->_block) {


          NSDictionary<NSString *, id> *changeWithKeyPath = change;

//将keyPath添加到字典中以便在观察多个keyPath时，能够清晰知道监听的是哪个keyPath
if (keyPath) {

            NSMutableDictionary<NSString *, id> *mChange = [NSMutableDictionary dictionaryWithObject:keyPath forKey:FBKVONotificationKeyPathKey];

            [mChange addEntriesFromDictionary:change];

            changeWithKeyPath = [mChange copy];

          }

          info->_block(observer, object, changeWithKeyPath);


        } else if (info->_action) {
//使用自定义方法回传监听结果
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Warc-performSelector-leaks"

          [observer performSelector:info->_action withObject:change withObject:object];
#pragma clang diagnostic pop

        } else {
//使用系统默认方法回传监听结果

          [observer observeValueForKeyPath:keyPath ofObject:object change:change context:info->_context];

        }

      }

    }

  }

}

- (void)unobserve:(id)object info:(nullable _FBKVOInfo *)info

{
if (nil == info) {
return;

  }

//先从HashTable中移除被监听的属性信息对象
pthread_mutex_lock(&_mutex);

  [_infos removeObject:info];
pthread_mutex_unlock(&_mutex);

// 当正在监听时，则移除监听
if (info->_state == _FBKVOInfoStateObserving) {

    [object removeObserver:self forKeyPath:info->_keyPath context:(void *)info];

  }
//修改被监听的状态

  info->_state = _FBKVOInfoStateNotObserving;

}

@interface NSObject (FBKVOController)
@property (nonatomic, strong) FBKVOController *KVOController;
@property (nonatomic, strong) FBKVOController *KVOControllerNonRetaining;
@end