资源描述：
《兄弟连Go语言+区块链技术培训以太坊源码分析(32)eth-downloader-peer源码分析.docx》由会员上传分享，免费在线阅读，更多相关内容在学术论文-天天文库。
1、兄弟连Go语言+区块链技术培训以太坊源码分析(32)eth-downloader-peer源码分析queue给downloader提供了调度功能和限流的功能。通过调用Schedule/ScheduleSkeleton来申请对任务进行调度，然后调用ReserveXXX方法来领取调度完成的任务，并在downloader里面的线程来执行，调用DeliverXXX方法把下载完的数据给queue。最后通过WaitResults来获取已经完成的任务。中间还有一些对任务的额外控制，ExpireXXX用来控制任务是
2、否超时，CancelXXX用来取消任务。##Schedule方法Schedule调用申请对一些区块头进行下载调度。可以看到做了一些合法性检查之后，把任务插入了blockTaskPool，receiptTaskPool，receiptTaskQueue，receiptTaskPool。TaskPool是Map，用来记录header的hash是否存在。TaskQueue是优先级队列，优先级是区块的高度的负数，这样区块高度越小的优先级越高，就实现了首先调度小的任务的功能。 //Schedul
3、eaddsasetofheadersforthedownloadqueueforscheduling,returning //thenewheadersencountered. //from表示headers里面第一个元素的区块高度。返回值返回了所有被接收的header func(q*queue)Schedule(headers[]*types.Header,fromuint64)[]*types.Header{ q.lock.Lock() deferq
4、.lock.Unlock() //Insertalltheheadersprioritisedbythecontainedblocknumber inserts:=make([]*types.Header,0,len(headers)) for_,header:=rangeheaders{ //Makesurechainorderishonouredandpreservedthroughout hash:=
5、header.Hash() ifheader.Number==nil
6、
7、header.Number.Uint64()!=from{ log.Warn("Headerbrokechainordering","number",header.Number,"hash",hash,"expected",from) break } //headerHead存储了最后一个插入的区块头，检
8、查当前区块是否正确的链接。 ifq.headerHead!=(common.Hash{})&&q.headerHead!=header.ParentHash{ log.Warn("Headerbrokechainancestry","number",header.Number,"hash",hash) break } //Makesurenoduplicaterequests
9、areexecuted //检查重复，这里直接continue了，那不是from对不上了。 if_,ok:=q.blockTaskPool[hash];ok{ log.Warn("Headeralreadyscheduledforblockfetch","number",header.Number,"hash",hash) continue } if_,
10、ok:=q.receiptTaskPool[hash];ok{ log.Warn("Headeralreadyscheduledforreceiptfetch","number",header.Number,"hash",hash) continue } //Queuetheheaderforcontentretrieval q.blockTa
