Sha256: db4b16a674e3f6dd8d212724df7620269334cd7e15bb352b422a747fedce48f9
Contents?: true
Size: 1.28 KB
Versions: 75
Compression:
Stored size: 1.28 KB
Contents
package com.rho;
public class Mutex
{
private Object m_mutex = new Object();
private int m_givenLocks = 0;
private Thread m_lockThread = null;
public void Lock()
{
synchronized (m_mutex) {
if ( m_lockThread == null || !m_lockThread.equals(Thread.currentThread()))
{
try {
while (m_givenLocks > 0) {
m_mutex.wait();
}
} catch (java.lang.InterruptedException e) {
System.out.println(e);
}
m_lockThread = Thread.currentThread();
}
m_givenLocks ++;
}
}
public void Unlock()
{
synchronized (m_mutex) {
if (m_givenLocks <= 0)
return;
m_givenLocks--;
if ( m_givenLocks == 0 )
m_lockThread = null;
m_mutex.notifyAll();
}
}
public boolean isLocked()
{
synchronized (m_mutex) {
return m_lockThread != null && !m_lockThread.equals(Thread.currentThread());
}
}
public boolean isHeldByCurrentThread()
{
synchronized (m_mutex) {
return m_lockThread != null && m_lockThread.equals(Thread.currentThread());
}
}
public boolean tryLock()
{
synchronized (m_mutex) {
if ( isLocked() )
return false;
Lock();
return true;
}
}
public int Sleep(int nSec)
{
Unlock();
try{
Thread.sleep(nSec*1000);
}catch(InterruptedException exc){}
Lock();
return nSec;
}
};
Version data entries
75 entries across 75 versions & 1 rubygems