ThreadPrivate.h

// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
//-----------------------------------------------------------------------------
// Copyright 2000-2022 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
// See the top-level COPYRIGHT file for details.
// SPDX-License-Identifier: Apache-2.0
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* ThreadPrivate.h                                             (C) 2000-2018 */
/*                                                                           */
/* Classe permettant de conserver une valeur spécifique par thread.          */
/*---------------------------------------------------------------------------*/
#ifndef ARCCORE_CONCURRENCY_THREADPRIVATE_H
#define ARCCORE_CONCURRENCY_THREADPRIVATE_H
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arccore/base/ArccoreGlobal.h"
 
#include "arccore/concurrency/GlibAdapter.h"
 
#include <vector>
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arccore
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
class ARCCORE_CONCURRENCY_EXPORT ThreadPrivateStorage
{
 public:
 
  ARCCORE_DEPRECATED_REASON("Y2022; This class is deprecated. Use 'thread_local' specifier.")
  ThreadPrivateStorage();
  ~ThreadPrivateStorage();
 
 public:
 
  void initialize();
  void* getValue();
  void setValue(void* v);
 private:
  GlibPrivate* m_storage;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
class ARCCORE_CONCURRENCY_EXPORT ThreadPrivateBase
{
 public:
  class ICreateFunctor
  {
   public:
    virtual ~ICreateFunctor(){}
    virtual void* createInstance() =0;
  };
 
 public:
 
  ARCCORE_DEPRECATED_REASON("Y2022; This class is deprecated. Use 'thread_local' specifier.")
  ThreadPrivateBase(ThreadPrivateStorage* key,ICreateFunctor* create_functor)
  : m_key(key), m_create_functor(create_functor) 
  {
  }
 
  ~ThreadPrivateBase()
  {
  }
 
 public:
 
 void* item();
 
 private:
 
  ThreadPrivateStorage* m_key;
  GlibMutex m_mutex;
  ICreateFunctor* m_create_functor;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
template<typename T>
class ThreadPrivate
: private ThreadPrivateBase::ICreateFunctor
{
 public:
 
  ARCCORE_DEPRECATED_REASON("Y2022; This class is deprecated. Use 'thread_local' specifier.")
  ThreadPrivate(ThreadPrivateStorage* key)
  : m_storage(key,this)
  {
  }
 
  ~ThreadPrivate()
  {
    for( T* item : m_allocated_items )
      delete item;
  }
 
 public:
  T* item()
  {
    return (T*)(m_storage.item());
  }
 
 private:
 
  void* createInstance() override
  {
    T* new_ptr = new T();
    new_ptr->build();
    m_allocated_items.push_back(new_ptr);
    return new_ptr;
  }
 
 private:
  std::vector<T*> m_allocated_items;
  ThreadPrivateBase m_storage;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // End namespace Arccore
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#endif