Okio Segment

segment中文意思是段恨课,部分,在這里是緩存數(shù)據(jù)存放的地方和措,數(shù)據(jù)就存放在一個一個的segment中庄呈,一個segment最大可存儲8192個字節(jié)。所有的segment以雙向循環(huán)鏈表的數(shù)據(jù)結構組織在一起派阱。

Segment類的成員變量

SIZE=8192诬留; 一個segment可存儲的最大字節(jié)數(shù)
SHARE_MINIMUM=1024; segment可被共享應含有的最小字節(jié)數(shù)(共享是為了不執(zhí)行拷貝操作)
byte[] data; 存放數(shù)據(jù)的字節(jié)數(shù)組
int pos贫母;下一個可讀的字節(jié)的位置
int limit文兑;下一個可寫的字節(jié)的位置
boolean shared;標識該segment是否是共享的
boolean owner; 標識該segment是否是字節(jié)數(shù)組的所有者(所有者可以修改腺劣,不是所有者是只讀權限)
Segment next; 鏈表中當前segment的下一個Segment
Segment prev;鏈表中當前segment的上一個Segment

Segment提供了從鏈表中刪除绿贞,插入以及相鄰segment的組合,一個segment拆分成兩個segment的操作橘原。

Segment.pop()

從鏈表中刪除自身籍铁。

prev ? 當前segment ? next -----> prev ? next
當前segment需要pop,那么當前segment 的next結點的prev指針就需要指向當前segment的prev結點趾断,當前segment的prev元素的next指針就需要指向當前segment的next結點拒名。

  public final @Nullable Segment pop() {
    Segment result = next != this ? next : null;
    prev.next = next;
    next.prev = prev;
    next = null;
    prev = null;
    return result;
  }

Segment.push(Segment)

將參數(shù)知道的segment插入到當前segment的后面
當前segment ? next -----> 當前segment ?插入的segment ? next
插入的segment的prev指針指向當前segment,插入的segment的next指針指向當前segment的next指針芋酌,當前segment的next結點的prev指針指向插入的segment增显,當前segment的next指針指向插入的segment。

  public final Segment push(Segment segment) {
    segment.prev = this;
    segment.next = next;
    next.prev = segment;
    next = segment;
    return segment;
  }

Segment.split(int byteCount)

將一個segment拆分成兩個segment脐帝,參數(shù)指定拆分后第一個segemnt含有的未讀字節(jié)數(shù)同云。所以第一個segment包含的數(shù)據(jù)范圍[pos,pos+ byteCount),第二個segment包含的數(shù)據(jù)范圍[pos+byteCount,limit)。
拆分時堵腹,當byteCount大于1024時使用共享segment炸站,否則執(zhí)行拷貝。這是出于兩方面考慮疚顷,一是避免拷貝數(shù)據(jù)旱易,所以使用共享的segment;二是避免過短的共享segment,以免鏈表中含有太多過短的segement咒唆。為了平衡兩者,規(guī)定共享的segment長度需要大于1024释液。

 public final Segment split(int byteCount) {
   //參數(shù)檢查全释,byteCount必須大于0,并且byteCount不能大于可讀數(shù)據(jù)長度
    if (byteCount <= 0 || byteCount > limit - pos) throw new IllegalArgumentException();
    Segment prefix;

    //當byteCount大于1024時使用共享segment误债,否則執(zhí)行拷貝
    if (byteCount >= SHARE_MINIMUM) {
      prefix = sharedCopy();//①
    } else {
    //從segment池中取出一個segment
      prefix = SegmentPool.take();//②
      System.arraycopy(data, pos, prefix.data, 0, byteCount);
    }

    prefix.limit = prefix.pos + byteCount;//設置prefix的limit指針(下一個可寫的位置)
    pos += byteCount;//設置當前segment的可讀指針位置
    prev.push(prefix);//將prefix segment插入segment鏈表
    return prefix;
  }

① sharedCopy()

final Segment sharedCopy() {
    shared = true;//當前為分享模式
   //創(chuàng)建一個分享的segment
    return new Segment(data, pos, limit, true, false);
  }

//Segment構造函數(shù)
  Segment(byte[] data, int pos, int limit, boolean shared, boolean owner) {
    this.data = data;
    this.pos = pos;
    this.limit = limit;
    this.shared = shared;
    this.owner = owner;
  }

② SegmentPool.take()

SegmentPool是未使用segment的集合浸船,采用單向鏈表組織在一起。只有兩個方法 take 和recycle寝蹈。

/**
 * 取出一個可用的segment 
 */
static Segment take() {
    synchronized (SegmentPool.class) {
//next指向下一個可用的segment
      if (next != null) {
        Segment result = next;
        next = result.next;//next指針指向next的下一個結點
        result.next = null; //返回的segment的next指針置為null
        byteCount -= Segment.SIZE;
        return result;
      }
    }
   //池中一個可用的segment都沒有李命,new 一個返回
    return new Segment(); 
  }
  
/**
  *回收一個segment
  */
static void recycle(Segment segment) {
//還在segment鏈中的segment不能回收
    if (segment.next != null || segment.prev != null) throw new IllegalArgumentException();
    if (segment.shared) return; //分享的segment不能回收
    synchronized (SegmentPool.class) {
      if (byteCount + Segment.SIZE > MAX_SIZE) return; //加入后超過池子大小的不能回收
      byteCount += Segment.SIZE;
     //將segment加入單鏈表頭部
      segment.next = next;
      segment.pos = segment.limit = 0;//重置讀寫指針
      next = segment;
    }
  }

Segment.compact()

將當前segment合并到前面一個segment。
首先計算當前segment可讀字節(jié)數(shù)箫老,然后計算前面一個segment可寫的字節(jié)數(shù)封字,這里分兩種情況,1耍鬓,前面一個segment是共享的阔籽,則剩余可寫的字節(jié)數(shù)=SIZE-prev.limit;2前面一個segment不是共享的牲蜀,那么其實pos前面的數(shù)據(jù)已經(jīng)是已讀的笆制,可以重新寫入,那么剩余可寫的字節(jié)數(shù)=SIZE-prev.limit+prev.pos涣达。比較當前segment可讀字節(jié)數(shù)與前面一個剩余可寫字節(jié)數(shù)大小在辆,如果前者大于后者,則不可寫入度苔,否則就寫入匆篓。

public final void compact() {
    if (prev == this) throw new IllegalStateException();
    if (!prev.owner) return; // Cannot compact: prev isn't writable.
   //當前segment可讀字節(jié)數(shù)
    int byteCount = limit - pos;
    //前面一個segment可寫字節(jié)數(shù)(注意:已讀的字節(jié)部分是可以重新寫的,這就是加上prev.pos的原因)
    int availableByteCount = SIZE - prev.limit + (prev.shared ? 0 : prev.pos);
    if (byteCount > availableByteCount) return; 

    writeTo(prev, byteCount);
    //當前segment從鏈表移除
    pop();
    //回收到segmentpool
    SegmentPool.recycle(this);
  }


  //將當前segment的未讀數(shù)據(jù)長度是byteCount寫到參數(shù)sink表示的segment中
  public final void writeTo(Segment sink, int byteCount) {
    if (!sink.owner) throw new IllegalArgumentException();
    if (sink.limit + byteCount > SIZE) {
      // 需要先將sink中已經(jīng)讀過的數(shù)據(jù)移走
      if (sink.shared) throw new IllegalArgumentException();
      if (sink.limit + byteCount - sink.pos > SIZE) throw new IllegalArgumentException();
      System.arraycopy(sink.data, sink.pos, sink.data, 0, sink.limit - sink.pos);
      sink.limit -= sink.pos;
      sink.pos = 0;
    }

    System.arraycopy(data, pos, sink.data, sink.limit, byteCount);
    sink.limit += byteCount;
    pos += byteCount;
  }

?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末林螃,一起剝皮案震驚了整個濱河市奕删,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌疗认,老刑警劉巖完残,帶你破解...
    沈念sama閱讀 216,919評論 6 502
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異横漏,居然都是意外死亡谨设,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,567評論 3 392
  • 文/潘曉璐 我一進店門缎浇,熙熙樓的掌柜王于貴愁眉苦臉地迎上來扎拣,“玉大人,你說我怎么就攤上這事《叮” “怎么了誉券?”我有些...
    開封第一講書人閱讀 163,316評論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長刊愚。 經(jīng)常有香客問我踊跟,道長,這世上最難降的妖魔是什么鸥诽? 我笑而不...
    開封第一講書人閱讀 58,294評論 1 292
  • 正文 為了忘掉前任商玫,我火速辦了婚禮,結果婚禮上牡借,老公的妹妹穿的比我還像新娘拳昌。我一直安慰自己,他們只是感情好钠龙,可當我...
    茶點故事閱讀 67,318評論 6 390
  • 文/花漫 我一把揭開白布炬藤。 她就那樣靜靜地躺著,像睡著了一般碴里。 火紅的嫁衣襯著肌膚如雪刻像。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,245評論 1 299
  • 那天并闲,我揣著相機與錄音细睡,去河邊找鬼。 笑死帝火,一個胖子當著我的面吹牛溜徙,可吹牛的內(nèi)容都是我干的蠢壹。 我是一名探鬼主播,決...
    沈念sama閱讀 40,120評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼撒汉,長吁一口氣:“原來是場噩夢啊……” “哼挠阁!你這毒婦竟也來了侵俗?” 一聲冷哼從身側響起隘谣,我...
    開封第一講書人閱讀 38,964評論 0 275
  • 序言:老撾萬榮一對情侶失蹤棵帽,失蹤者是張志新(化名)和其女友劉穎逗概,沒想到半個月后卿城,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,376評論 1 313
  • 正文 獨居荒郊野嶺守林人離奇死亡氢烘,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,592評論 2 333
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片木西。...
    茶點故事閱讀 39,764評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡恋捆,死狀恐怖膜毁,靈堂內(nèi)的尸體忽然破棺而出瘟滨,到底是詐尸還是另有隱情,我是刑警寧澤能颁,帶...
    沈念sama閱讀 35,460評論 5 344
  • 正文 年R本政府宣布杂瘸,位于F島的核電站,受9級特大地震影響伙菊,放射性物質(zhì)發(fā)生泄漏败玉。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,070評論 3 327
  • 文/蒙蒙 一镜硕、第九天 我趴在偏房一處隱蔽的房頂上張望运翼。 院中可真熱鬧,春花似錦兴枯、人聲如沸血淌。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,697評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽六剥。三九已至,卻和暖如春峰伙,著一層夾襖步出監(jiān)牢的瞬間疗疟,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,846評論 1 269
  • 我被黑心中介騙來泰國打工瞳氓, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留策彤,地道東北人。 一個月前我還...
    沈念sama閱讀 47,819評論 2 370
  • 正文 我出身青樓匣摘,卻偏偏與公主長得像店诗,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子音榜,可洞房花燭夜當晚...
    茶點故事閱讀 44,665評論 2 354

推薦閱讀更多精彩內(nèi)容