ObservablePool.h

// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
//-----------------------------------------------------------------------------
// Copyright 2000-2026 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
// See the top-level COPYRIGHT file for details.
// SPDX-License-Identifier: Apache-2.0
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* ObserverPool.h                                              (C) 2000-2025 */
/*                                                                           */
/* List of observables.                                                      */
/*---------------------------------------------------------------------------*/
#ifndef ARCANE_CORE_OBSERVABLEPOOL_H
#define ARCANE_CORE_OBSERVABLEPOOL_H
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arcane/utils/FatalErrorException.h"
 
#include "arcane/core/Observable.h"
#include "arcane/core/Observer.h"
 
#include <map>
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
class IObservable;
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/

template <typename KeyType>
class ObservablePool
{
 public:
 
  typedef std::map<KeyType, IObservable*> ObservableListType;
 
 public:

  ObservablePool() {}
  ~ObservablePool()
  {
    for (const auto& x : m_observables) {
      IObservable* o = x.second;
      o->detachAllObservers();
      delete o;
    }
  }
 
 public:
 
  void add(const KeyType& key)
  {
    IObservable* x = _getIfExists(key);
    if (x)
      ARCANE_FATAL("Observable with current key already exists");
    m_observables.insert(std::make_pair(key, new Observable()));
  }
 
  IObservable* operator[](const KeyType& key)
  {
    IObservable* x = _getIfExists(key);
    if (!x)
      ARCANE_FATAL("No observable with current key exists");
    return x;
  }
 
 protected:
 private:
 
  ObservableListType m_observables; 
 
  IObservable* _getIfExists(const KeyType& key) const
  {
    auto x = m_observables.find(key);
    if (x != m_observables.end())
      return x->second;
    return nullptr;
  }
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // End namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#endif