类图 ReadWriteLock Sync ReentrantReadWriteLock内部的Sync的类图如下: 构造 默认构造器: 1public ReentrantReadWriteLock() { 2 this(false); 3} 含参构造器: 1public ReentrantReadWriteLock(boolean fair) { 2 sync = fair ? new FairSync() : new NonfairSync(); 3 readerLock = new ReadLock(this); 4 writerLock = new WriteLock(this); 5} 写锁和读锁的构造器是一个套路，以读锁为 …

阅读更多

ReentrantLock 类图 如下: Sync 观察ReentrantLock关键方法的源码可以发现，其实现是委托给内部类Sync实现的，所以逻辑的关键便在于此类。例子: 1public void lock() { 2 sync.lock(); 3} 类图 很明显，锁的公平性便是由NonFairSync和FairSync实现的，从ReentrantLock的构造器可以印证这一点: 1public ReentrantLock(boolean fair) { 2 sync = fair ? new FairSync() : new NonfairSync(); 3} 锁的公平性指的是等待时间最长的线程最有机会获得锁，但是这样会导致性 …

阅读更多

核心便是Class类，类图如下: 方法获取 我们以getDeclaredMethods为例: 1@CallerSensitive 2public Method[] getDeclaredMethods() throws SecurityException { 3 return copyMethods(privateGetDeclaredMethods(false)); 4} privateGetDeclaredMethods: 1private Method[] privateGetDeclaredMethods(boolean publicOnly) { 2 Method[] res; 3 ReflectionData<T> rd …

阅读更多

创建 我们一般使用下面的方式进行创建: 1public static ScheduledExecutorService newSingleThreadScheduledExecutor() { 2 return new DelegatedScheduledExecutorService(new ScheduledThreadPoolExecutor(1)); 3} DelegatedScheduledExecutorService实际上是对ScheduledExecutorService接口方法的转发，目的是只将ScheduledExecutorService接口的public方法暴露出来，这其实就是门面模式。 显然这里的核心便 …

阅读更多

客户端连接 先来看一下使用socket作为客户端的使用。假设有代码如下: 1public static void main(String[] args) { 2 Socket socket = new Socket(); 3 socket.connect(new InetSocketAddress(8080)); 4} 构造器 Socket的默认构造器源码如下: 1 public Socket() { 2 setImpl(); 3} setImpl()方法的目的在于设置系统采用的Socket实现，采用SocksSocketImpl。其类图: SocksSocketImpl.jpg的父类会在静态代码块中进行初始化工作，下面分部分说明。 …

阅读更多

一.简介 1.GNU源代码开发精神 2.STL版本 3.SGI STL头文件分布 4.STL六大部件 二.空间分配器 1.空间分配器的标准接口 2.SGI标准的空间分配器std::allocator 3.SGI特殊的空间分配器std::alloc 3.1 对象构造与析构 3.2 内存分配与释放 1）两级分配器 2）第一级分配器__malloc_alloc_template 3）第二级分配器__default_alloc_template 3.3 内存基本处理工具 三.迭代器与traits编程技法 1.迭代器相应类型 2.traits编程技法 3.std::iterator的保证 4.SGI STL的__type_traits 四. …

阅读更多

构造器 我们以喜闻乐见的为例: 1public Thread(Runnable target) { 2 init(null, target, "Thread-" + nextThreadNum(), 0); 3} 第一个参数为线程组，最后一个为栈大小。init方法就是一些内部属性的赋值操作。 启动 1public synchronized void start() { 2 if (threadStatus != 0) 3 throw new IllegalThreadStateException(); 4 boolean started = false; 5 start0(); 6 started = true; 7} 核心 便在 …

阅读更多

get 1public T get() { 2 Thread t = Thread.currentThread(); 3 ThreadLocalMap map = getMap(t); 4 if (map != null) { 5 ThreadLocalMap.Entry e = map.getEntry(this); 6 if (e != null) { 7 @SuppressWarnings("unchecked") 8 T result = (T)e.value; 9 return result; 10 } 11 } 12 return setInitialValue(); 13} getMap实现: …

阅读更多

创建 我们以下列代码为例: 1public static ExecutorService newFixedThreadPool(int nThreads) { 2 return new ThreadPoolExecutor(nThreads, nThreads, 3 0L, TimeUnit.MILLISECONDS, 4 new LinkedBlockingQueue<Runnable>()); 5} 可见默认使用LinkedBlockingQueue作为工作队列，其构造器: 1public LinkedBlockingQueue() { 2 this(Integer.MAX_VALUE); 3} 可见，这其实是一个有界队列，虽然 …

阅读更多

类图: TreeMap的构造器可以接受一个Comparator参数用以决定key的顺序，如果没有指定，那么尝试将key强转为Comparable，如果转换失败那就抛出异常了。 put 1public V put(K key, V value) { 2 Entry<K,V> t = root; 3 if (t == null) { 4 compare(key, key); // type (and possibly null) check 5 root = new Entry<>(key, value, null); 6 size = 1; 7 modCount++; 8 return null; 9 } 10 int cmp; 11 …

阅读更多