GlibThreadImplementation.cc

// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
//-----------------------------------------------------------------------------
// Copyright 2000-2025 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
// See the top-level COPYRIGHT file for details.
// SPDX-License-Identifier: Apache-2.0
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* GlibThreadImplementation.cc                                 (C) 2000-2025 */
/*                                                                           */
/* Implémentation des threads utilisant la glib.                             */
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arccore/base/NotImplementedException.h"
#include "arccore/base/IFunctor.h"
 
#include "arccore/concurrency/GlibThreadImplementation.h"
#include "arccore/concurrency/IThreadBarrier.h"
#include "arccore/concurrency/Mutex.h"
#include "arccore/concurrency/GlibAdapter.h"
 
#include <new>
#include <glib.h>
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
static void* _GlibStartFunc(void* f)
{
  IFunctor* ff = reinterpret_cast<IFunctor*>(f);
  ff->executeFunctor();
  return 0;
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
class GlibThreadBarrier
: public IThreadBarrier
{
 public:
 
  GlibThreadBarrier()
  : m_wait_mutex(nullptr)
  , m_wait(nullptr)
  , m_nb_thread(0)
  , m_current_reached(0)
  {}
 
 public:
 
  virtual void init(Integer nb_thread)
  {
    m_nb_thread = nb_thread;
    m_current_reached = 0;
    m_wait_mutex = new GlibMutex();
    m_wait = new GlibCond();
  }
 
  virtual void destroy()
  {
    m_nb_thread = 0;
    m_current_reached = 0;
    delete m_wait_mutex;
    delete m_wait;
    delete this;
  }
 
  virtual bool wait()
  {
    bool is_last = false;
    m_wait_mutex->lock();
    ++m_current_reached;
    //cout << "ADD BARRIER N=" << m_current_reached << '\n';
    if (m_current_reached == m_nb_thread) {
      m_current_reached = 0;
      is_last = true;
      //cout << "BROADCAST BARRIER N=" << m_current_reached << '\n';
      m_wait->broadcast();
    }
    else
      m_wait->wait(m_wait_mutex);
    m_wait_mutex->unlock();
    return is_last;
  }
 
 private:
 
  GlibMutex* m_wait_mutex;
  GlibCond* m_wait;
  Integer m_nb_thread;
  Integer m_current_reached;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
extern "C" ARCCORE_CONCURRENCY_EXPORT IThreadBarrier*
createGlibThreadBarrier()
{
  return new GlibThreadBarrier();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
GlibThreadImplementation::
GlibThreadImplementation()
: m_global_mutex_impl(nullptr)
{
}
 
GlibThreadImplementation::
~GlibThreadImplementation()
{
  GlobalMutex::destroy();
  if (m_global_mutex_impl)
    destroyMutex(m_global_mutex_impl);
}
 
void GlibThreadImplementation::
initialize()
{
  m_global_mutex_impl = createMutex();
  GlobalMutex::init(m_global_mutex_impl);
}
 
ThreadImpl* GlibThreadImplementation::
createThread(IFunctor* f)
{
  return reinterpret_cast<ThreadImpl*>(g_thread_new(nullptr, &_GlibStartFunc, f));
}
 
void GlibThreadImplementation::
joinThread(ThreadImpl* t)
{
  GThread* tt = reinterpret_cast<GThread*>(t);
  g_thread_join(tt);
}
 
void GlibThreadImplementation::
destroyThread(ThreadImpl* t)
{
  ARCCORE_UNUSED(t);
}
 
void GlibThreadImplementation::
createSpinLock(Int64* spin_lock_addr)
{
  volatile gint* v = (gint*)spin_lock_addr;
  g_bit_unlock(v, 0);
}
 
void GlibThreadImplementation::
lockSpinLock(Int64* spin_lock_addr, Int64* scoped_spin_lock_addr)
{
  ARCCORE_UNUSED(scoped_spin_lock_addr);
 
  volatile gint* v = (gint*)spin_lock_addr;
  if (!g_bit_trylock(v, 0)) {
    do {
      //TODO: Faire Pause
    } while (!g_bit_trylock(v, 0));
  }
}
 
void GlibThreadImplementation::
unlockSpinLock(Int64* spin_lock_addr, Int64* scoped_spin_lock_addr)
{
  ARCCORE_UNUSED(scoped_spin_lock_addr);
 
  volatile gint* v = (gint*)spin_lock_addr;
  g_bit_unlock(v, 0);
}
 
MutexImpl* GlibThreadImplementation::
createMutex()
{
  GlibMutex* m = new GlibMutex();
  return reinterpret_cast<MutexImpl*>(m);
}
 
void GlibThreadImplementation::
destroyMutex(MutexImpl* mutex)
{
  GlibMutex* m = reinterpret_cast<GlibMutex*>(mutex);
  delete m;
}
 
void GlibThreadImplementation::
lockMutex(MutexImpl* mutex)
{
  GlibMutex* m = reinterpret_cast<GlibMutex*>(mutex);
  m->lock();
}
 
void GlibThreadImplementation::
unlockMutex(MutexImpl* mutex)
{
  GlibMutex* m = reinterpret_cast<GlibMutex*>(mutex);
  m->unlock();
}
 
Int64 GlibThreadImplementation::
currentThread()
{
  Int64 v = reinterpret_cast<Int64>(g_thread_self());
  return v;
}
 
IThreadBarrier* GlibThreadImplementation::
createBarrier()
{
  return new GlibThreadBarrier();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/