admin管理员组文章数量:1599541
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.AbstractQueuedLongSynchronizer;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.LockSupport;
import java.util.concurrent.locks.ReentrantLock;
/**
* * @Date:2021/2/25 13:15
**/
public class ConditionDemo {
final static ReentrantLock reentrantLock = new ReentrantLock();
final static Condition condition = reentrantLock.newCondition();
public static void main(String[] args) {
Thread t1 = new Thread(() -> t1(), "thread1");
Thread t2 = new Thread(() -> t2(), "thread2");
t1.setPriority(1);
t1.start();
//并不一定会等优先级高的线程先执行
t2.setPriority(10);
t2.start();
}
public static void t1() {
reentrantLock.lock();
try {
System.out.println(Thread.currentThread().getName() + "在等待被唤醒");
// Thread.currentThread().interrupt();
//如果interrupted,则抛出异常
//调用await方法后,将当前线程加入Condition等待队列中。当前线程释放锁。否则别的线程就无法拿到锁而发生死锁。
// 自旋(while)挂起,不断检测节点是否在同步队列中了,如果是则尝试获取锁,否则挂起。
// 当线程被signal方法唤醒,被唤醒的线程将从await()方法中的while循环中退出来,然后调用acquireQueued()方法竞争同步状态。
//https://wwwblogs/gemine/p/9039012.html
// condition.await();
//等待指定时间,此时不唤醒,则会在5秒后唤醒
// condition.await(5,TimeUnit.SECONDS);
//返回值表示剩余时间,如果在nanosTimesout之前唤醒,那么返回值 = nanosTimeout - 消耗时间,
// 如果返回值 <= 0 ,则可以认定它已经超时了。
long nanos = TimeUnit.SECONDS.toNanos(5);
long x = condition.awaitNanos(nanos);
System.out.println(x);
System.out.println(Thread.currentThread().getName() + "恢复执行了");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
reentrantLock.unlock();
System.out.println("thead 1 执行完了");
}
}
public static void t2() {
reentrantLock.lock();
try {
System.out.println(Thread.currentThread().getName() + "抢到了锁");
//调用Condition的signal()方法,将会唤醒在等待队列中等待最长时间的节点(条件队列里的首节点),
// 在唤醒节点前,会将节点移到同步队列中
//唤醒后await会退出while循环,随后加入到同步状态的竞争当中去。
// 成功获取到竞争的线程则会返回到await方法之前的状态。
// condition.signal();
System.out.println(Thread.currentThread().getName() + "唤醒其它等待的线程");
} catch (Exception e) {
e.printStackTrace();
} finally {
reentrantLock.unlock();
}
}
}
/*
第一种情况:
thread1 condition.await();
thread2 condition.signal();
1. 如果thread1先抢到资源 则正常await,然后thread2执行 并signal唤醒 ,然后thread1退出循环并执行完毕
2. 如果thread2先抢到资源 则thread2执行完,然后thread1执行,thread1 await,一直等待,不会被唤醒
第二种情况:
thread1 condition.await();
// thread2 condition.signal(); 注释此行
1. 如果thread1先抢到资源 则正常await,然后thread2执行 ,然后thread1一直循环等待被唤醒
2. 如果thread2先抢到资源 则thread2执行完,然后thread1执行,thread1 await,一直等待,不会被唤醒
第三种情况:
thread1 condition.await(5,TimeUnit.SECONDS);
// thread2 condition.signal(); 注释此行
1. 如果thread1先抢到资源 则正常await,然后thread2执行 ,然后thread1一直循环等待被唤醒,直到指定时间,即5秒后退出循环,执行完
2. 如果thread2先抢到资源 则thread2执行完,然后thread1执行,thread1 await,一直等待,直到指定时间,即5秒后退出循环,执行完
第四种情况:
thread1 long nanos = TimeUnit.SECONDS.toNanos(5);
long x = condition.awaitNanos(nanos);
System.out.println(x);
thread2 condition.signal();
1. 如果thread1先抢到资源 则正常await,然后thread2执行 signal唤醒 ,然后thread1退出循环,输出时间为正数 执行完
2. 如果thread2先抢到资源 则thread2执行完,然后thread1执行,thread1 await,一直等待,直到指定时间,即5秒后退出循环,输出时间为负数,执行完
第五种情况:
thread1 long nanos = TimeUnit.SECONDS.toNanos(5);
long x = condition.awaitNanos(nanos);
System.out.println(x);
//thread2 condition.signal(); 注释此行
1. 如果thread1先抢到资源 则正常await,然后thread2执行 ,然后thread1一直循环等待 ,直到五秒 ,输出时间为负数 执行完
2. 如果thread2先抢到资源 则thread2执行完,然后thread1执行,thread1 await,一直等待,直到指定时间,即5秒后退出循环,输出时间为负数 执行完
*/
本文标签: conditionawaitawaitNanos
版权声明:本文标题:Condition.await 和 awaitNanos 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://m.elefans.com/dianzi/1728322135a1153963.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论