异步的文件通道，FileChannel属于"同步非阻塞"，AsynchronousFileChannel才是真正的异步。 从主要方法read/write的返回值为Future可以看出其"异步"的端倪。 open 1public static AsynchronousFileChannel open(Path file, 2 Set<? extends OpenOption> options, 3 ExecutorService executor, 4 FileAttribute<?>... attrs) { 5 FileSystemProvider provider = …

阅读更多

Buffer 说到nio就离不开Buffer体系，类图: 这里以ByteBuffer为例，其实对于布尔类型的其它所有基本类型，都与一种Buffer与之对应，比如还有ShortBuffer。 图中的getXXX指的是获得各种数据类型的便利方法，比如getChar，getInt，putXXX也是一样。asXXX指到其它类型Buffer的转换方法，比如asCharBuffer。 注意，只有ByteBuffer才拥有getXXX, putXXX, asXXX等向其它类型转换的方法，也只有ByteBuffer可以获取direct类型的buffer。 获取 allocate 得到heap buffer，源码: 1public static …

阅读更多

概览 BufferedInputStream的主要方法均为线程安全，其内部的byte数组的最大值为int的最大值减去8，这样做的原因是在Java中数组是一个对象，而一个对象最大拥有8字节的对象头。至于为什么是int的最大值而不是long的最大值，需要同时支持32位和64位虚拟机吧。 字段count的取值范围为[0, buf.length]，意义为[0, count)范围内的字节都是可读的，字段pos的取值范围为[0, count)，即读指针的位置。 read 1public synchronized int read() throws IOException { 2 if (pos >= count) { 3 fill(); 4 …

阅读更多

我们对JDK1.8版本的ConcurrentHashMap进行说明，1.8版本的ConcurrentHashMap相比之前的版本主要做了两处改进: 使用CAS代替分段锁。 红黑树，这一点和HashMap是一致的。 put 最核心的便是put方法: 1public V put(K key, V value) { 2 return putVal(key, value, false); 3} 最后一个参数为onlyIfAbsent，表示只有在key对应的value不存在时才将value加入，所以putVal是put和putIfAbsent两个方法的真正实现。 1final V putVal(K key, V value, boolean …

阅读更多

内部类Node的类图如下: 算法 此类的实现基于算法Michael & Scott algorithm，论文: Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Queue Algorithms offer 1public boolean offer(E e) { 2 //如果元素为null，那么抛出NPE 3 checkNotNull(e); 4 final Node<E> newNode = new Node<E>(e); 5 for (Node<E> t = tail, p = t;;) { 6 //volatile读 7 Node<E> q = …

阅读更多

Condition 类图 ConditionObject是AbstractQueuedSynchronizer的内部类。 创建 创建是通过Lock.newCondition()来完成的。 ReentrantLock.newCondition: 1public Condition newCondition() { 2 return sync.newCondition(); 3} Sync.newCondition: 1final ConditionObject newCondition() { 2 return new ConditionObject(); 3} await ConditionObject.await: 1public …

阅读更多

CountDownLatch 类图 CountDownLatch本身没有任何父类或是实现任何接口，只含有一个内部类Sync. await CountDownLatch.await: 1public void await() throws InterruptedException { 2 sync.acquireSharedInterruptibly(1); 3} AbstractQueuedSynchronizer.acquireSharedInterruptibly: 1public final void acquireSharedInterruptibly(int arg) throws InterruptedException …

阅读更多

CyclicBarrier 此类可管理一组线程，当所有线程都到达"检查点"时执行特定的动作(Runnable)，示例直接看其源码便好。 类图 和CountDownLatch类似，此类同样没有任何父类(除了Object)或是实现任何接口。 await 整个类的核心便是此方法: 1public int await() { 2 return dowait(false, 0L); 3} doWait方法简略版源码: 1private int dowait(boolean timed, long nanos) { 2 final ReentrantLock lock = this.lock; 3 lock.lock(); 4 try { 5 …

阅读更多

说明 对枚举这一看似平常的东西单开一节的目的是要探究一下为什么说枚举是最好的实现单例的方式。 从例子开始 假设有这么一个简单的枚举: 1public enum Test { 2 3 SOMEONE, 4 5 ANOTHER_ONE 6 7} 首先对其进行编译，然后使用命令javap -verbose Test.class对其反编译，得到如下部分: 1public final class Test extends java.lang.Enum<Test> {} 所以，对于Java来说，枚举是一个语法糖。 Why Enum的类图: finalize Enum中将finalize方法直接定义为final，这就从根本上上避免了枚举类对此方法 …

阅读更多

我们以FileOutputStream的getChannel为例: 1public FileChannel getChannel() { 2 synchronized (this) { 3 if (channel == null) { 4 channel = FileChannelImpl.open(fd, path, false, true, append, this); 5 } 6 return channel; 7 } 8} FileChannel类图: 有几点值得注意: InputStream和OutputStream不是线程安全的，而通道(Channel)是线程安全的。 Channel根据注释的解释，是一组IO操作的联结。 …

阅读更多