notifier.h

Go to the documentation of this file.

#ifndef ION_BASE_NOTIFIER_H_
#define ION_BASE_NOTIFIER_H_

#include <algorithm>

#include "ion/base/lockguards.h"
#include "ion/base/readwritelock.h"
#include "ion/base/stlalloc/allocvector.h"
#include "ion/base/weakreferent.h"
#include "ion/port/mutex.h"

namespace ion {
namespace base {

class ION_API Notifier : public WeakReferent {
 public:
  void AddReceiver(Notifier* receiver);

  void RemoveReceiver(Notifier* receiver);

  size_t GetReceiverCount() const;

 protected:
  typedef WeakReferentPtr<Notifier> NotifierPtr;
  typedef AllocVector<NotifierPtr> NotifierPtrVector;

  Notifier() : receivers_(*this) {}
  ~Notifier() override;

  const NotifierPtrVector& GetReceivers() const;

  void Notify() const;

  virtual void OnNotify(const Notifier* notifier);

 private:
  mutable NotifierPtrVector receivers_;
  mutable base::ReadWriteLock mutex_;
};

}  // namespace base
}  // namespace ion

#endif  // ION_BASE_NOTIFIER_H_