当前位置: 首页 > news >正文

佛山市seo网络推广公司衡阳百度seo

佛山市seo网络推广公司,衡阳百度seo,商标注册全是坑,站点推广以 ReentrantLock#lock() 的非公平锁实现为例 结论:节点在加入等待队列后会进行两次自旋,获取不到锁后线程挂起,等待前驱节点唤醒。 此外,AQS 在节点加入队列前也会多次尝试获取资源,通过以上方式,在高并…

以 ReentrantLock#lock() 的非公平锁实现为例

结论:节点在加入等待队列后会进行两次自旋,获取不到锁后线程挂起,等待前驱节点唤醒

此外,AQS 在节点加入队列前也会多次尝试获取资源,通过以上方式,在高并发场景中很好的平衡了 长时间自旋的开销 和 线程阻塞的性能损耗(频繁的上下文切换)

核心代码:

// AbstractQueuedSynchronizer
// 线程直接获取资源失败,加入等待队列,通过自旋 + 阻塞获取锁
final boolean acquireQueued(final Node node, int arg) {boolean failed = true;try {boolean interrupted = false;// 自旋操作,for 循环中并没有明确的自旋次数,答案藏在 shouldParkAfterFailedAcquire() 中for (;;) {final Node p = node.predecessor();// 检查是否能获取资源if (p == head && tryAcquire(arg)) {setHead(node);p.next = null; // help GCfailed = false;return interrupted;}// 检查是否需要阻塞if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())interrupted = true;}} finally {if (failed)cancelAcquire(node);}
}// AbstractQueuedSynchronizer
// 检查线程是否需要阻塞
private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {int ws = pred.waitStatus;// SIGNAL 状态表明应该阻塞if (ws == Node.SIGNAL)return true;// 对应的节点状态是 CANCELLED,直接跳过if (ws > 0) {do {node.prev = pred = pred.prev;} while (pred.waitStatus > 0);pred.next = node;} else {// 剩余的情况都会将前驱节点的状态置为 SIGNAL// 这样在下一次自旋时就会返回 true,进入阻塞,也就是自旋两次的由来compareAndSetWaitStatus(pred, ws, Node.SIGNAL);}return false;
}

完整加锁链路:

// ReentrantLock
public void lock() {sync.lock();
}// ReentrantLock#Sync
abstract void lock();// ReentrantLock#NonfairSync
final void lock() {// 资源空闲时直接获取if (compareAndSetState(0, 1))setExclusiveOwnerThread(Thread.currentThread());else// 资源被占用时acquire(1);
}// AbstractQueuedSynchronizer
public final void acquire(int arg) {if (!tryAcquire(arg) &&acquireQueued(addWaiter(Node.EXCLUSIVE), arg))selfInterrupt();
}// ReentrantLock#NonfairSync
protected final boolean tryAcquire(int acquires) {return nonfairTryAcquire(acquires);
}// ReentrantLock#Sync
// 该方法做了两件事情:资源空闲时获取资源、当前线程重入获取资源(ReentrantLock 是可重入锁)
final boolean nonfairTryAcquire(int acquires) {final Thread current = Thread.currentThread();int c = getState();if (c == 0) {if (compareAndSetState(0, acquires)) {setExclusiveOwnerThread(current);return true;}}else if (current == getExclusiveOwnerThread()) {int nextc = c + acquires;if (nextc < 0) // overflowthrow new Error("Maximum lock count exceeded");setState(nextc);return true;}return false;
}// AbstractQueuedSynchronizer
// 线程直接获取资源失败,加入等待队列,通过自旋 + 阻塞获取锁
final boolean acquireQueued(final Node node, int arg) {boolean failed = true;try {boolean interrupted = false;// 自旋操作,for 循环中并没有明确的自旋次数,答案藏在 shouldParkAfterFailedAcquire() 中for (;;) {final Node p = node.predecessor();// 检查是否能获取资源if (p == head && tryAcquire(arg)) {setHead(node);p.next = null; // help GCfailed = false;return interrupted;}// 检查是否需要阻塞if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())interrupted = true;}} finally {if (failed)cancelAcquire(node);}
}// AbstractQueuedSynchronizer
// 检查线程是否需要阻塞
private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {int ws = pred.waitStatus;// SIGNAL 状态表明应该阻塞if (ws == Node.SIGNAL)return true;// 对应的节点状态是 CANCELLED,直接跳过if (ws > 0) {do {node.prev = pred = pred.prev;} while (pred.waitStatus > 0);pred.next = node;} else {// 剩余的情况都会将前驱节点的状态置为 SIGNAL// 这样在下一次自旋时就会返回 true,进入阻塞,也就是自旋两次的由来compareAndSetWaitStatus(pred, ws, Node.SIGNAL);}return false;
}

http://www.cadmedia.cn/news/6872.html

相关文章:

  • 如何申请国外网站西安seo站内优化
  • 合肥网站设计建设公司设计培训学院
  • 新开的网站建设公司如何推广外媒头条最新消息
  • 建站管理后台手机地图app下载安装
  • 鹤壁市建设工程交易中心网站百度信息流投放方式有哪些
  • 网站建设图济南网络seo公司
  • 网站建设的好处哪些广告平台留号码
  • 网站建设询价公告竞价账户托管公司
  • 自己做网站建议关键词优化靠谱推荐
  • 政府网站建设工作存在的不足如何做免费网站推广
  • 宁德市住房和城乡建设局网站广州百度推广外包
  • 网站建设顺序百度快速排名技术培训教程
  • 求手机视频网站关键词优化的技巧
  • 个人备案的网站做企业内容百度竞价什么时候开始的
  • 上海市工程建设信息网怎样下载优化大师
  • 济南市建设委员会官方网站做个网页需要多少钱?
  • 岳阳seo官网优化用户体验
  • 湖南网站建设oqiandu业务推广网站
  • 工业网站建设永久免费客服系统软件
  • 招聘网站建设工作汇报搜索引擎优化的主要手段
  • 河北网站建设联系方式网络推广平台几大类
  • 中国最近的好消息网站seo快速
  • 网站设置黑白色网站怎么做
  • 长页在线制作网站企业培训机构排名
  • 苏省住房和城乡建设厅网站创建免费网站
  • 网站制作设计机构在线制作网站免费
  • 网站建设需要几个阶段网络营销方案3000字
  • 哈尔滨建站模板展示网页制作三大软件
  • 宁波网站建设xpckj百度数据库
  • 平台做网站点击百度产品