java.util.concurrent.locks.StampedLock#asReadLock()源码实例Demo

下面列出了java.util.concurrent.locks.StampedLock#asReadLock() 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: dragonwell8_jdk   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码2 项目: TencentKona-8   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码3 项目: native-obfuscator   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码4 项目: jdk8u60   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码5 项目: openjdk-jdk8u   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码6 项目: jdk8u-dev-jdk   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码7 项目: openjdk-jdk8u-backup   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码8 项目: openjdk-8   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码9 项目: openjdk-jdk9   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码10 项目: jdk8u-jdk   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码11 项目: hottub   文件: Basic.java
static Reader interruptibleReaderView(final StampedLock sl,
                                      final long timeout,
                                      final TimeUnit unit,
                                      final Phaser gate) {
    return new Reader("InterruptibleReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();

        try {
            if (timeout < 0)
                rl.lockInterruptibly();
            else
                rl.tryLock(timeout, unit);
            stamp(1L);  // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } catch (Throwable x) { thrown(x);
        } finally { if (stamp() != 0L) rl.unlock(); } }};
}
 
源代码12 项目: dragonwell8_jdk   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码13 项目: TencentKona-8   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码14 项目: native-obfuscator   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码15 项目: jdk8u-jdk   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码16 项目: openjdk-8   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码17 项目: jdk8u_jdk   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码18 项目: jdk8u-jdk   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码19 项目: hottub   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}
 
源代码20 项目: openjdk-8-source   文件: Basic.java
static Reader readerView(final StampedLock sl, final Phaser gate) {
    return new Reader("ReaderView") { public void run() {
        if (gate != null ) toTheStartingGate(gate);
        final Lock rl = sl.asReadLock();
        rl.lock();
        try {
            stamp(1L);   // got the lock
            check(sl.isReadLocked());
            check(!sl.isWriteLocked());
        } finally { rl.unlock(); } }};
}