概述 ThreadLocal提供了一种线程安全的数据访问方式，每个线程中都存在一个共享变量副本，从而实现多线程状态下的线程安全。 demopublic static void main(String[] args) {final ThreadLocal<Integer> MAIN = ThreadLocal.withInitial(() -> 100);MAIN.set(200);new Thread(()->{System.out.println(Thread.currentThread().getName() + " MAIN:" + MAIN.get());}).start();System.out.println("MAIN:" + MAIN.get());//一定要注意...
其中绿色代表接口，橘色代表的是实现类由结构图可以看来HashSet实现了Set接口，LinkedHashSet为HashSet的子类。 添加一个元素的时候会先得到hash值，会转化为索引值 找到存储数据表table，看这个索引位置是否存放有元素 如果没有直接加入、如果有就调用equals方法比较，如果相同，就放弃添加，如果不同就添加到最后。 java8中，如果一个链表的元素个数>=treeify_threshold(默认为8)，并且table的大小>=64就会进行树化（红黑树） 如...
一、基本概念：Resource：Ambari把可以被管理的资源的抽象为一个Resource实例，资源可以包括服务、组件、主机节点等，一个resource实例中包含了一系列该资源的属性；Property：服务组件的指标名称；ResourceProvider和PropertyProvider分别对应Resource和Property的提供方，获取指标需要先获取Resource，然后获取Property对应的metric；Query:Query是Resource的内部对象，代表了对该资源的操作；Request：一个Request代表了对Resou...
死磕以太坊源码分析之p2p节点发现在阅读节点发现源码之前必须要理解kadmilia算法，可以参考：KAD算法详解。 节点发现概述 节点发现，使本地节点得知其他节点的信息，进而加入到p2p网络中。 以太坊的节点发现基于类似的kademlia算法，源码中有两个版本，v4和v5。v4适用于全节点，通过discover.ListenUDP使用，v5适用于轻节点通过discv5.ListenUDP使用，本文介绍的是v4版本。 节点发现功能主要涉及 Server Table udp 这几个数据结构，...
目录窗口尺寸概述窗口Size消息的处理用户调整Size消息的处理调整窗口大小程序调整窗口大小wxScrolledWindow设置窗口大小获取TextCtrl控件最合适大小窗口尺寸概述类型说明Size当前窗口实际大小，通过wxWindow::SetSize()获取；Client Size客户区大小；Best Size最合适的大小，用户可以实现wxWindow::DoGetBestSize()方法，自定义返回最合适的大小；Best Client Size最合适的客户区大小，用户可以实现DoGetBestClientSize方法实现自定...
Quartz 核心部分是scheduler. 1、首先看下quartz的一个实例的运行流程图： 2、先创建Schedulerfactory。使用SchedulerFactory的实现类StdSchedulerFactory创建一个SchedulerFactory实例。在创建factory之初，jvm不实例化任何成员变量，仅仅是一个空的构造方法。 3、获取scheduler。通过schedulerfactory获取scheduler。获取scheduler需要一系列的参数，这些参数我们可以配置application.yml中，在spring boot启动...
前言 JDK1.5 之后发布了JUC（java.util.concurrent），用于解决多线程并发问题。AQS 是一个特别重要的同步框架，很多同步类都借助于 AQS 实现了对线程同步状态的管理。 AQS 中最主要的就是独占锁和共享锁的获取和释放，以及提供了一些可中断的获取锁，超时等待锁等方法。 ReentranLock 是基于 AQS 独占锁的一个实现。ReentrantReadWriteLock 是基于 AQS 共享锁的一个读写锁实现。本来打算一篇文章里面写完独占锁和共享锁，但是发现...
DelayQueue 顾名思义,它是一个延时队列 使用方式 :假设我们生产者提交一个任务，消费者5秒钟之后才可以执行，那么我们可以把任务定义为如下格式，并实现Delayed接口，其中data是任务存储的信息。/*** 具体的任务* @author wangshixiang*/ public class Task implements Delayed {/*** 数据*/private final String data;/*** 任务执行时间*/private final long time;public Task(String data,TimeUnit timeUnit,long time){this.dat...
1. 概述 CopyOnWriteArrayList，从名字可以看出它跟 ArrayList 有点关系，可以理解为线程安全的 ArrayList。它的类签名和继承结构如下： public class CopyOnWriteArrayList<E>implements List<E>, RandomAccess, Cloneable, java.io.Serializable {} 它主要实现了 List 接口，也是一个集合类，下面分析其代码实现。 2. 代码分析 仍然先从构造器进行分析。 2.1 构造器 // 构造器一：无参构造器 public CopyOnWriteArrayList() {set...
release-1.20功能概述 源码走读 kube-proxy 入口： kubernetes/cmd/kube-proxy/proxy.go启动命令： /hyperkube proxy --v=2 --kubeconfig=/etc/kubernetes/kube-proxy-kubeconfig.yaml --bind-address=10.164.28.57 --cluster-cidr=100.101.0.0/16 --proxy-mode=iptables --oom-score-adj=-998 --healthz-bind-address=10.164.28.57配置信息： cat /etc/kubernetes/kube-proxy-kubeconfig.yaml apiVersion: v1 kind: Config cluste...
tornado中HTTP服务器是承上启下的作用，它通过tornado.http1connection.HTTP1ServerConnection与tornado.http1connection.HTTP1Connection从socket中读取并解析http消息然后调用application处理解析出来的http消息，具体方法为：将application作为数据处理类传给上述两个读取数据的类具体代码如下#常见的torando启动方式 application = tornado.web.Application(Handlers) application.listen(8888) class Application(ReversibleR...
Mybatis相关组件 --> <dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.3.0</version> </dependency> <dependency><groupId>org.mybatis</groupId><artifactId>mybatis-spring</artifactId><version>1.2.3</version> </dependency> 系列的文章也是mybatis 3.3.0和mybatis-spring1.2.3分析 mybatis jar包中只要包含mybaits的核心业务sqlsession,sqlsessionFactory,configuration mybatis-spr...
代码在后面 读锁 = 共享锁 读锁写锁，公用一个Sync AQS state。 写锁是排他的，看到有人获取锁，他不会去获取，他获取了锁，别人也不会进来获取锁。 写锁的获取跟ReentarntLock一样，每次加1，是一个独占锁，只要有人获取了锁，自己就去排队，排队时候节点是EXCLUSIVE的节点，入队方法acquireQueued和ReentarntLock一样，会设置OwnerThread。 读锁先获取锁，后面有读锁进来，多个读线程共存时候，第一个读线程设置firstReade...
try {List<Author> authors = session.selectList("org.apache.ibatis.domain.blog.mappers.AuthorMapper.selectAllAuthors");assertEquals(2, authors.size());} finally {session.close();当然从某种意义上来讲，写起有一点烦。但是不可否认他的功能的确存在。这也是笔者为什么比较喜欢用动态代理来进行数据上的操作。至少可观性上笔者认为比较好吧。 不管是哪一种数据上的操作都离不开SqlSession接口实例。所以深入查看qlSessio...
线程安全问题:在添加时候并没有进行安全考虑,枷锁所以是线程不安全的,接下来进行代码测试;package com.mmall.concurrency.example.commonUnsafe;import com.mmall.concurrency.annoations.NotThreadSafe; import lombok.extern.slf4j.Slf4j;import java.util.HashMap; import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; i...