构造器 我们以喜闻乐见的为例: 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 …

阅读更多

一个简单的Server/Client交互过程参见udp包。从中可以看出其实对于UDP来说，服务器和客户端代码其实是一样的。在此我们将"服务器"简单的理解为数据的接收方。 类图 DatagramSocket DatagramSocketImpl 数据接收 示例代码: 1DatagramSocket server = new DatagramSocket(8080); 2byte[] buffer = new byte[1024]; 3DatagramPacket packet = new DatagramPacket(buffer, 1024); 4server.receive(packet); …

阅读更多

类图: 我们以urlconnection包的简单对百度首页的读取来开启我们的源码阅读旅程。 连接建立 相关源码: 1//http://www.baidu.com 2URL realUrl = new URL(urlName); 3URLConnection conn = realUrl.openConnection(); 4conn.setRequestProperty("accept", "/"); 5conn.setRequestProperty("connection", "Keep-Alive"); 6conn.setRequestProperty("user-agent", "Mozilla/4.0 …

阅读更多