test/loops/LongMutex.java

/*
 * Written by Doug Lea with assistance from members of JCP JSR-166
 * Expert Group and released to the public domain, as explained at
 * http://creativecommons.org/publicdomain/zero/1.0/
 */

import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.locks.*;
import java.util.concurrent.atomic.*;
import java.io.*;

/**
 * A sample user extension of AbstractQueuedLongSynchronizer.
 */
public final class LongMutex extends AbstractQueuedLongSynchronizer implements Lock, java.io.Serializable {
    static final long LOCKED = -1L;
    public boolean isHeldExclusively() { return getState() == LOCKED; }

    public boolean tryAcquire(long acquires) {
        return compareAndSetState(0, LOCKED);
    }

    public boolean tryRelease(long releases) {
        setState(0);
        return true;
    }
    public Condition newCondition() { return new ConditionObject(); }

    private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException {
        s.defaultReadObject();
        setState(0); // reset to unlocked state
    }

    public void lock() {
        acquire(LOCKED);
    }
    public boolean tryLock() {
        return tryAcquire(LOCKED);
    }
    public void lockInterruptibly() throws InterruptedException {
        acquireInterruptibly(LOCKED);
    }
    public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException {
        return tryAcquireNanos(LOCKED, unit.toNanos(timeout));
    }
    public void unlock() { release(LOCKED); }
}
Revision:	1.3
Committed:	Tue Mar 15 19:47:05 2011 UTC (13 years, 2 months ago) by jsr166
Branch:	MAIN
CVS Tags:	release-1_7_0
Changes since 1.2:	+1 -1 lines
Log Message:	Update Creative Commons license URL in legal notices
#	User	Rev	Content
1	dl	1.1	/*
2			* Written by Doug Lea with assistance from members of JCP JSR-166
3			* Expert Group and released to the public domain, as explained at
4	jsr166	1.3	* http://creativecommons.org/publicdomain/zero/1.0/
5	dl	1.1	*/
6
7			import java.util.*;
8			import java.util.concurrent.*;
9			import java.util.concurrent.locks.*;
10			import java.util.concurrent.atomic.*;
11			import java.io.*;
12
13			/**
14	jsr166	1.2	* A sample user extension of AbstractQueuedLongSynchronizer.
15	dl	1.1	*/
16			public final class LongMutex extends AbstractQueuedLongSynchronizer implements Lock, java.io.Serializable {
17			static final long LOCKED = -1L;
18			public boolean isHeldExclusively() { return getState() == LOCKED; }
19	jsr166	1.2
20	dl	1.1	public boolean tryAcquire(long acquires) {
21			return compareAndSetState(0, LOCKED);
22			}
23	jsr166	1.2
24	dl	1.1	public boolean tryRelease(long releases) {
25			setState(0);
26			return true;
27			}
28			public Condition newCondition() { return new ConditionObject(); }
29	jsr166	1.2
30	dl	1.1	private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException {
31			s.defaultReadObject();
32			setState(0); // reset to unlocked state
33			}
34
35	jsr166	1.2	public void lock() {
36			acquire(LOCKED);
37	dl	1.1	}
38	jsr166	1.2	public boolean tryLock() {
39	dl	1.1	return tryAcquire(LOCKED);
40			}
41	jsr166	1.2	public void lockInterruptibly() throws InterruptedException {
42	dl	1.1	acquireInterruptibly(LOCKED);
43			}
44			public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException {
45			return tryAcquireNanos(LOCKED, unit.toNanos(timeout));
46			}
47			public void unlock() { release(LOCKED); }
48			}