clockworkpi/LauncherGoDev
1
0
Fork 0
mirror of https://github.com/clockworkpi/LauncherGoDev.git synced 2025-12-12 07:58:51 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

warehouse update

Browse Source
This commit is contained in:
cuu 2021-10-28 17:03:37 +08:00
parent d7ce515e62
commit 64ba30a811
1 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
Menu/GameShell/21_Warehouse/ware_house_page.go
View File

@ -115,6 +115,7 @@ func (self *WareHouse) GetAria2DownloadingPercent(url string) int {
} }
func (self *WareHouse) UpdateProcessInterval(ms int) { func (self *WareHouse) UpdateProcessInterval(ms int) {
dirty := false dirty := false
L:
for { for {
select { select {
case <- self.RefreshTicker.C: case <- self.RefreshTicker.C:
@ -136,6 +137,10 @@ func (self *WareHouse) UpdateProcessInterval(ms int) {
self.Screen.SwapAndShow() self.Screen.SwapAndShow()
} }
dirty = false dirty = false
case v:= <- self.Downloading:
if v== false {
break L
}
} }
} }
} }
@ -398,16 +403,25 @@ func (self *WareHouse) Init() {
} }
self.rpcc = rpcc self.rpcc = rpcc
self.Downloader = grab.NewClient() self.Downloader = grab.NewClient()
self.Downloading = make(chan bool) self.Downloading = make(chan bool,1)
self.RefreshTicker = gotime.NewTicker(500 * gotime.Millisecond) self.RefreshTicker = gotime.NewTicker(500 * gotime.Millisecond)
//self.RefreshTicker.Stop() //self.RefreshTicker.Stop()
self.SetDownloading(true)
go self.UpdateProcessInterval(500) go self.UpdateProcessInterval(500)
} }
} }
func (self *WareHouse) SetDownloading(v bool) {
for len(self.Downloading) > 0 {
<- self.Downloading
}
self.Downloading <- v
}
func (self *WareHouse) ResetHouse() { func (self *WareHouse) ResetHouse() {
if self.PsIndex > len(self.MyList) -1 { if self.PsIndex > len(self.MyList) -1 {
return return
@ -755,6 +769,17 @@ func (self *WareHouse) OnKbdReturnBackCb() {
} }
} }
func (self *WareHouse) OnExitCb() {
if self.RefreshTicker != nil {
self.RefreshTicker.Stop()
}
self.SetDownloading(false)
self.rpcc.Close()
}
func (self *WareHouse) OnLoadCb() { func (self *WareHouse) OnLoadCb() {
if self.MyStack.Length() == 1 { if self.MyStack.Length() == 1 {