Commitebf86dd

Alex Belozierov

committed

- QosFifoQueue refactoring

1 parent2e5cfcc commitebf86ddCopy full SHA for ebf86dd

File tree

-18

lines changed

-18

lines changed

Lines changed: 4 additions & 17 deletions

Original file line number	Diff line number	Diff line change
`@@ -12,39 +12,26 @@ extension PQosThreadPool {`
`12`	`12`
`13`	`13`	`privatetypealiasQueue=FifoQueue<T>`
`14`	`14`	`privateletqueues= UnsafeMutablePointer<Queue>.allocate(capacity:4)`
`15`		`-privatevarcount=0`
`16`	`15`
`17`	`16`	`init(){`
`18`	`17`	`letqueues=(0..<4).map{ _inQueue()}`
`19`	`18`	`self.queues.initialize(from: queues, count:4)`
`20`	`19`	`}`
`21`	`20`
`22`	`21`	`@inlinablefunc push(_ item:T, qos:Qos){`
`23`		`- count+=1`
`24`	`22`	`queues[qos.rawValue].push(item)`
`25`	`23`	`}`
`26`	`24`
`27`	`25`	`@inlinablefunc push(_ items:[T], qos:Qos){`
`28`		`- count+= items.count`
`29`	`26`	`queues[qos.rawValue].push(items)`
`30`	`27`	`}`
`31`	`28`
`32`		`-@discardableResultfunc pop()->T?{`
`33`		`-if count==0{returnnil}`
`34`		`-foriin0..<4{`
`35`		`-guardlet item=queues[i].pop()else{continue}`
`36`		`- count-=1`
`37`		`-return item`
`38`		`-}`
`39`		`-returnnil`
	`29`	`+@inlinablefunc pop(qos:Qos)->T?{`
	`30`	`+returnqueues[qos.rawValue].pop()`
`40`	`31`	`}`
`41`	`32`
`42`		`-@inlinablevarfirstQos:Qos?{`
`43`		`-if count==0{returnnil}`
`44`		`-foriin0..<4wherequeues[i].first!=nil{`
`45`		`-returnQos(rawValue: i)`
`46`		`-}`
`47`		`-returnnil`
	`33`	`+varfirstQos:Qos?{`
	`34`	`+return(0..<4).first{ !queues[$0].isEmpty}.flatMap(Qos.init)`
`48`	`35`	`}`
`49`	`36`
`50`	`37`	`deinit{`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ extension PQosThreadPool {`
`23`	`23`	`cancelPerfom()`
`24`	`24`	`returnnil`
`25`	`25`	`}`
`26`		`-returnperfromNext(qos: qos)? poolState.queue.pop():nil`
	`26`	`+returnperfromNext(qos: qos)? poolState.queue.pop(qos: qos):nil`
`27`	`27`	`}`
`28`	`28`
`29`	`29`	`privatefunc perfromNext(qos:Qos)->Bool{`

Comments

(0)