修护死锁
This commit is contained in:
parent
390fb8cdd0
commit
cd01d1758a
4
main.go
4
main.go
@ -186,7 +186,8 @@ func runMainProcess() { // 主进程逻辑
|
|||||||
|
|
||||||
if processed { // 如果尚未处理
|
if processed { // 如果尚未处理
|
||||||
log.Printf("\033[33m %s 已经标记为国内,跳过!!! \033[0m\n", ipStr)
|
log.Printf("\033[33m %s 已经标记为国内,跳过!!! \033[0m\n", ipStr)
|
||||||
continue
|
IpList.Remove(e1)
|
||||||
|
goto next
|
||||||
}
|
}
|
||||||
|
|
||||||
if Is_Ip_Ipset(ipStr) != 0 { // IP 不在 ipset 集合中
|
if Is_Ip_Ipset(ipStr) != 0 { // IP 不在 ipset 集合中
|
||||||
@ -219,6 +220,7 @@ func runMainProcess() { // 主进程逻辑
|
|||||||
// 无论是否已处理,都移除该 IP
|
// 无论是否已处理,都移除该 IP
|
||||||
IpList.Remove(e1)
|
IpList.Remove(e1)
|
||||||
}
|
}
|
||||||
|
next:
|
||||||
IpMutex.Unlock() // 解锁互斥锁
|
IpMutex.Unlock() // 解锁互斥锁
|
||||||
|
|
||||||
log.Printf(" 当前Ip链表长度:%d, Ipset名:%s, 长:%d ProcessedIPMap当前长度:%d\n", IpList.Len(), IPSET_NAME, func() int { // 打印 当前 Ipset 链长度
|
log.Printf(" 当前Ip链表长度:%d, Ipset名:%s, 长:%d ProcessedIPMap当前长度:%d\n", IpList.Len(), IPSET_NAME, func() int { // 打印 当前 Ipset 链长度
|
||||||
|
Loading…
x
Reference in New Issue
Block a user