请教ACE_Process_Mutex的问题！(贴上了代码)

codecola

我用ACE_Process_Mutex设置一个进程锁，为了实现一个主机只能启动一个程序。
在调用tryacquire()返回0，再调用acquire()时，在linux平台下会将整个程序死锁，而在windows下正常，怎么回事？
各位大虾，请指教！


凭记忆写的，代码大概是这样的：

class Process_Mutex
{
public:
    Process_Mutex(ACE_Process_Mutex mutex);
    ~Process_Mutex();

    int acquire();

private:
    ACE_Process_Mutex &m_mutex;
};

Process_Mutex::Process_Mutex(ACE_Process_Mutex mutex)
{
     m_mutex = mutex;
}

Process_Mutex::~Process_Mutex()
{
    m_mutex.release();
}

int Process_Mutex::acquire()
{
    int result m_mutex.tryacquire();
    if (result < 0)
    {
        return -1;
    }
    else
    {
        m_mutex.acquire();       // linux下阻塞
    }
    return 0;
}


//调用
ACE_Process_Mutex p_mutex;
Process_Mutex mutex(p_mutex);
if (mutex.acquire() < 0)
{
    ACE_DEBUG((LM_ERROR, "error\n"));
}

[ 本帖最后由 codecola 于 2008-11-26 16:02 编辑 ]

winston

你的问题没法解决。啥线索也没有啊。
至少把代码贴上来看看啊。

winston

linux下应该是必死的代码。
这里面涉及到线程重入的概念，这行：
int result m_mutex.tryacquire();
如果返回成功0，就已经表明获取了锁，再次m_mutex.acquire();焉能不死。
linux不可重入。但是windows下，同一个线程是可以重入的。

codecola

谢谢老大

在网上找到下面的相关资料


ACE中的Thread Mutex在linux下的使用
ACE库中专门对线程同步提供了两个类，一个是ACE_Thread_Mutex另一个是ACE_REcursive_Thread_Mutex。 在我看 来，在linux下进行线程同步，不要使用ACE_Thread_Mutex，用ACE_REcursive_Thread_Mutex就可以了。原因很 简单，因为ACE_Thread_Mutex不支持线程重入。一旦重入(同一个线程调用两次ACE_Thread_Mutex::acquire）这个线 程就死锁了。

要搞清楚这个问题，我们需要搞清楚操作系统是如何实现线程锁的。Windows下很简单，用CRITICAL_SECTION实现。 CRITICAL_SECTION支持重入，所以Windows下的线程同步用ACE_Thread_Mutex或者 ACE_REcursive_Thread_Mutex都是一样的。而linux下不同，是用posix thread 库实现的。pthread 的mutex分为三种类型，fast,recursive,error checking,当线程调用pthread_mutex_lock时，如果是线程重入这把锁，则：

“fast”锁 挂起当前线程.
“resursive”锁 成功并立刻返回当前被锁定的次数
“error checking” 锁立刻返回EDEADLK

显然ACE_Thread_Mutex是用fast方式实现的。

我有多个平台 (Window,AIX ，Solaris,hp-ux,Linux)的C++多线程程序的开发经验,但是一直都没有想清楚一个不可重入的线程锁有什么用，用这样的锁用起来太不方便，要很小心了， 一不小心就会死锁。所以一般情况下都需要手工写代码将它封装成一个可以重入的锁。ACE中也提供了这样一个封装，用mutex和cond实现的，代码如 下:

ACE_OS::recursive_mutex_lock (ACE_recursive_thread_mutex_t *m)
{
#if defined (ACE_HAS_THREADS)
#if defined (ACE_HAS_RECURSIVE_MUTEXES)
return ACE_OS::thread_mutex_lock (m);
#else
ACE_thread_t t_id = ACE_OS::thr_self ();
int result = 0;

// Acquire the guard.
if (ACE_OS::thread_mutex_lock (&m->nesting_mutex_) == -1)
result = -1;
else
{
// If there’s no contention, just grab the lock immediately
// (since this is the common case we’ll optimize for it).
if (m->nesting_level_ == 0)
m->owner_id_ = t_id;
// If we already own the lock, then increment the nesting level
// and return.
else if (ACE_OS::thr_equal (t_id, m->owner_id_) == 0)
{
// Wait until the nesting level has dropped to zero, at
// which point we can acquire the lock.
while (m->nesting_level_ > 0)
ACE_OS::cond_wait (&m->lock_available_,
&m->nesting_mutex_);

// At this point the nesting_mutex_ is held…
m->owner_id_ = t_id;
}

// At this point, we can safely increment the nesting_level_ no
// matter how we got here!
m->nesting_level_++;
}

{
// Save/restore errno.
ACE_Errno_Guard error (errno);
ACE_OS::thread_mutex_unlock (&m->nesting_mutex_);
}
return result;
#endif /* ACE_HAS_RECURSIVE_MUTEXES */
#else
ACE_UNUSED_ARG (m);
ACE_NOTSUP_RETURN (-1);
#endif /* ACE_HAS_THREADS */
}

这个封装是用在那些posix thread库不支持recursive mutex的平台上的。如果posix thread支持recursive ，那么直接用pthread_mutex_lock就可以了。所以我的结论是：在ACE环境下，直接使用ACE_REcursive_Thread_Mutex，忘记 ACE_Thread_Mutex的存在。


http://www.linuxgoo.com/2005/68120/12133551173.html

[ 本帖最后由 codecola 于 2008-11-27 09:12 编辑 ]

woodasan

Process_Mutex的构造函数应该传递引用吧，不应按值传递
Process_Mutex::Process_Mutex(ACE_Process_Mutex &mutes)

codecola

原帖由 woodasan 于 2008-11-27 19:26 发表
Process_Mutex的构造函数应该传递引用吧，不应按值传递
Process_Mutex::Process_Mutex(ACE_Process_Mutex &mutes)

是的，我写错了