mutex_pool.cpp
上传用户:yhdzpy8989
上传日期:2007-06-13
资源大小:13604k
文件大小:4k
源码类别:

生物技术

开发平台:

C/C++

  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: mutex_pool.cpp,v $
  4.  * PRODUCTION Revision 1000.1  2004/06/01 19:23:26  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.5
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  9. /*  $Id: mutex_pool.cpp,v 1000.1 2004/06/01 19:23:26 gouriano Exp $
  10. * ===========================================================================
  11. *
  12. *                            PUBLIC DOMAIN NOTICE
  13. *               National Center for Biotechnology Information
  14. *
  15. *  This software/database is a "United States Government Work" under the
  16. *  terms of the United States Copyright Act.  It was written as part of
  17. *  the author's official duties as a United States Government employee and
  18. *  thus cannot be copyrighted.  This software/database is freely available
  19. *  to the public for use. The National Library of Medicine and the U.S.
  20. *  Government have not placed any restriction on its use or reproduction.
  21. *
  22. *  Although all reasonable efforts have been taken to ensure the accuracy
  23. *  and reliability of the software and data, the NLM and the U.S.
  24. *  Government do not and cannot warrant the performance or results that
  25. *  may be obtained by using this software or data. The NLM and the U.S.
  26. *  Government disclaim all warranties, express or implied, including
  27. *  warranties of performance, merchantability or fitness for any particular
  28. *  purpose.
  29. *
  30. *  Please cite the author in any work or product based on this material.
  31. *
  32. * ===========================================================================
  33. *
  34. * Authors:
  35. *           Eugene Vasilchenko
  36. *
  37. * File Description:
  38. *           Pool of mutexes for initialization of objects
  39. *
  40. */
  41. #include <ncbi_pch.hpp>
  42. #include <objmgr/impl/mutex_pool.hpp>
  43. BEGIN_NCBI_SCOPE
  44. BEGIN_SCOPE(objects)
  45. /////////////////////////////////////////////////////////////////////////////
  46. // CInitMutexPool
  47. /////////////////////////////////////////////////////////////////////////////
  48. CInitMutexPool::CInitMutexPool(void)
  49. {
  50. }
  51. CInitMutexPool::~CInitMutexPool(void)
  52. {
  53. }
  54. bool CInitMutexPool::AcquireMutex(CInitMutex_Base& init, CRef<TMutex>& mutex)
  55. {
  56.     _ASSERT(!mutex);
  57.     CRef<TMutex> local(init.m_Mutex);
  58.     if ( !local ) {
  59.         CFastMutexGuard guard(m_Pool_Mtx);
  60.         if ( init )
  61.             return false;
  62.         local = init.m_Mutex;
  63.         if ( !local ) {
  64.             if ( m_MutexList.empty() ) {
  65.                 local.Reset(new TMutex(*this));
  66.                 local->DoDeleteThisObject();
  67.             }
  68.             else {
  69.                 local = m_MutexList.front();
  70.                 m_MutexList.pop_front();
  71.             }
  72.             init.m_Mutex = local;
  73.         }
  74.     }
  75.     _ASSERT(local);
  76.     mutex = local;
  77.     _ASSERT(mutex);
  78.     return true;
  79. }
  80. void CInitMutexPool::ReleaseMutex(CInitMutex_Base& init, CRef<TMutex>& mutex)
  81. {
  82.     _ASSERT(mutex);
  83.     //_ASSERT(init);
  84.     CRef<TMutex> local(mutex);
  85.     mutex.Reset();
  86.     _ASSERT(local);
  87.     if ( init.m_Mutex ) {
  88.         CFastMutexGuard guard(m_Pool_Mtx);
  89.         init.m_Mutex.Reset();
  90.         if ( local->ReferencedOnlyOnce() ) {
  91.             m_MutexList.push_back(local);
  92.         }
  93.     }
  94.     else {
  95.         if ( local->ReferencedOnlyOnce() ) {
  96.             CFastMutexGuard guard(m_Pool_Mtx);
  97.             m_MutexList.push_back(local);
  98.         }
  99.     }
  100.     _ASSERT(!mutex);
  101. }
  102. END_SCOPE(objects)
  103. END_NCBI_SCOPE
  104. /*
  105. * ---------------------------------------------------------------------------
  106. * $Log: mutex_pool.cpp,v $
  107. * Revision 1000.1  2004/06/01 19:23:26  gouriano
  108. * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.5
  109. *
  110. * Revision 1.5  2004/05/21 21:42:12  gorelenk
  111. * Added PCH ncbi_pch.hpp
  112. *
  113. * Revision 1.4  2003/07/01 18:02:37  vasilche
  114. * Removed invalid assert.
  115. * Moved asserts from .hpp to .cpp file.
  116. *
  117. * Revision 1.3  2003/06/25 17:09:28  vasilche
  118. * Fixed locking in CInitMutexPool.
  119. *
  120. * Revision 1.2  2003/06/24 14:25:18  vasilche
  121. * Removed obsolete CTSE_Guard class.
  122. * Used separate mutexes for bioseq and annot maps.
  123. *
  124. * Revision 1.1  2003/06/19 18:23:46  vasilche
  125. * Added several CXxx_ScopeInfo classes for CScope related information.
  126. * CBioseq_Handle now uses reference to CBioseq_ScopeInfo.
  127. * Some fine tuning of locking in CScope.
  128. *
  129. *
  130. * ===========================================================================
  131. */