private Object wrapCollection(final Object object) {
if (object instanceof List) {
return new HashMap() {{
put("list", object);
}};
} else if (object != null && object.getClass().isArray()) {
return new HashMap() {{
put("array", object);
}};
}
return object;
}
2，BufferedInputStream类的实现是其内部有一个字节数组作为缓冲区，默认大小为8K字节，还有一个AtomicReferenceFieldUpdater用来对这个缓冲区进行比较和赋值，这主要是防止在赋值时，其他调用者调用了close方法，导致缓冲区为null,因此将这个赋值动作做成原子化操作。读数据的时候，如果缓存区是空的，一种特别的情况就是要读的字节数大于或等于缓冲区长度，并且没有mark和set操作过，那么就直接从底层的输入流中读取，否则就重新填充缓冲区，再从缓冲区中读取数据。填充缓冲区时，主要要考虑有没有mark标志的，对其分别进行处理，当然最主要的操作还是对缓冲区扩容，重新从底层输入流中读取数据，
public void close() throws IOException
{
byte[] buffer;
while ((buffer = buf) != null) {
if (bufUpdater.compareAndSet(this, buffer, null)) {
InputStream input = in;
in = null;
if (input != null)
input.close();
return;
}
}
最新评论