用户中心USER CENTER

首页/用户
  • 从0到1实现自己的阻塞队列(下)

    摘要:在上一篇文章从到实现自己的阻塞队列上中,我们已经实现了一个可以使用的阻塞队列版本。插入锁队列未满的条件变量弹出锁队列非空的条件变量最后我们要对和方法中的调用做出一些调整。 在上一篇文章《从0到1实现自己的阻塞队列(上)》中,我们已经实现了一个可以使用的阻塞队列版本。在这篇文章中,我们可以继续我们的冒险之旅,将我们的阻塞队列提升到接近JDK版本的水平上。 更进一步优化效率 我们一直使用的...

    XFLY 发布于Java
  • 《从0到1学习Flink》—— Data Source 介绍

    摘要:指定了该迭代器返回元素的类型。这可能导致节点故障后的恢复速度较慢,因为该作业将从最后一个检查点恢复读取。监听的端口过来的数据这个在从到学习上搭建环境并构建运行简单程序入门文章里用的就是基于的程序。取消一个,也即将中的循环元素的行为终止。 showImg(https://segmentfault.com/img/remote/1460000016944116); 前言 Data Sou...

    XFLY 发布于Java
  • 中间件 - ZooKeeper应用场景实践

    摘要:三分布式锁这部分是重要功能,在此基础上实现诸如,分布式协调通知,负载均衡,选举等复杂场景。针对此情况,改进后判断读写顺序为创建完临时顺序节点后,获取下的所有子节点。 注:该文章用作回顾记录 一、准备工作 预先下载安装 ZooKeeper ,简单配置就能使用了。然后构建 Maven 项目,将下面的代码粘贴到 pom.xml中: org.apache.zook...

    XFLY 发布于Java
  • 消息队列学习(二)

    摘要:的全称是,即消息服务。它主要用于在生产者和消费者之间进行消息传递,生产者负责产生消息,而消费者负责接收消息。会话是生产和消费消息的一个单线程上下文。消息消息由以下三部分组成消息头。 今天我们以ActiveMQ为例进行一系列的学习 Apache ActiveMQ是Apache软件基金会所研发的开放源码消息中间件;由于ActiveMQ是一个纯Java框架,那么我们先要了解下java中的JM...

    XFLY 发布于Java
  • [LeetCode] Integer Replacement

    摘要:记一种简单的的做法先讨论边界,若为最大值,返回然后对整数分奇偶两种情况讨论,偶数除以,奇数判断是否后能被整除且不等于,若如此则,否则每次操作后计数器,循环结束后返回计数器值。 Problem Given a positive integer n and you can do operations as follow: If n is even, replace n with n/2.I...

    XFLY 发布于Java
<