ThreadPrivate.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
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* ThreadPrivate.h                                             (C) 2000-2025 */
/*                                                                           */
/* Class for storing a specific value per thread.                            */
/*---------------------------------------------------------------------------*/
#ifndef ARCCORE_CONCURRENCY_THREADPRIVATE_H
#define ARCCORE_CONCURRENCY_THREADPRIVATE_H
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arccore/base/ArccoreGlobal.h"
 
#include "arccore/concurrency/GlibAdapter.h"
 
#include <vector>
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/

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;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#endif