1 Star 0 Fork 54

Joker Hou/kasini3000

forked from chuanjiao10/kasini3000 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
kaiiit_后台任务_rs.ps1 3.77 KB
一键复制 编辑 原始数据 按行查看 历史
chuanjiao10 提交于 2020-12-15 14:07 . 优化k-commit,k-commit-rs逻辑
#建议保存编码为:bom头 + utf8
#
Start-Sleep -Seconds 1
if ( ($IsWindows -eq $True) -or ($PSVersionTable.psversion.major -lt 6) ) #win
{
& 'c:\ProgramData\kasini3000\0k_source.ps1'
}
if ($IsLinux -eq $True)
{
& '/etc/kasini3000/0k_source.ps1'
}
#main
#建立pid文件
& 'kaiiit_写pid_rs.ps1'
& 'k_写log.ps1' -被写入的log内容 " $pid【kaiiit-rs】开始运行"
Write-Error '信息:k-commit-rs.ps1 后台任务现在开始运行!'
$private:超过此时间则退出 = (Get-Date).AddMinutes(72)
$global:kaiiit_rs_循环中 = $True
$private:本进程_内的最大线程数_已经超过 = $false
$private:已经fork过新进程 = $false
while ($global:kaiiit_rs_循环中 -eq $True)
{
& 'end_invoke_福报表_rs.ps1'
#超过1小时12分钟,强制退出。
if ($private:超过此时间则退出 -lt (Get-Date))
{
$global:kaiiit_rs_循环中 = $false
}
if ($private:已经fork过新进程 -eq $false)
{
& 'begin_invoke_福报表_rs.ps1'
}
$private:当前福报数 = (Get-RSJob).count
if ($private:当前福报数 -gt $global:kcommitrs并发线程数_单进程)
{
$private:本进程_内的最大线程数_已经超过 = $True
}
# 超过线程数,则只fork一次新进程。
if ( ($private:本进程_内的最大线程数_已经超过 -eq $True) -and ($private:已经fork过新进程 -eq $false))
{
$private:已经fork过新进程 = $true
& 'k_写log.ps1' -被写入的log内容 "错误:$pid 现有rs福报数太多。 ${private:当前福报数} "
& 'kaiiit_删pid_rs.ps1'
if ($global:kcommitrs_ps版本)
{
if ( ($IsWindows -eq $True) -or ($PSVersionTable.psversion.major -lt 6) ) #win
{
Start-Process -FilePath "$global:kcommitrs_的ps版本" -ArgumentList " -WindowStyle hidden -file ${global:kasini3000目录}/kaiiit_后台任务_rs.ps1"
}
if ($IsLinux -eq $True)
{
Start-Process -FilePath "$global:kcommitrs_的ps版本" -ArgumentList " -file ${global:kasini3000目录}/kaiiit_后台任务_rs.ps1"
}
}
else
{
Write-Error "错误:k-commit-rs.ps1中,找不到变量【$global:kcommitrs_的ps版本】,错误码3"
exit 3
}
}
if ($global:kaiiit后台任务_循环间隔_秒)
{
Start-Sleep -Seconds $global:kaiiit后台任务_循环间隔_
}
else
{
Start-Sleep -Seconds 10
}
if ($private:当前福报数 -le 0)
{
if ($private:已经fork过新进程 -eq $true)
{
$global:kaiiit_rs_循环中 = $false
$private:temp995 = "{0}【kaiiit-rs】结束运行" -f $pid
& 'k_写log.ps1' -被写入的log内容 $private:temp995
Write-Error '信息:所有 k-commit-rs.ps1 后台任务运行完毕!'
}
else
{
if ($script:等待1分钟)
{
if ((Get-Date) -gt $script:等待1分钟)
{
$global:kaiiit_rs_循环中 = $false
$private:temp995 = "{0}【kaiiit-rs】结束运行" -f $pid
& 'k_写log.ps1' -被写入的log内容 $private:temp995
Write-Error '信息:所有 k-commit-rs.ps1 后台任务运行完毕!'
}
}
else
{
$script:等待1分钟 = (Get-Date).AddMinutes(1)
}
}
}
else
{
$private:temp995 = "{0}现有福报rs任务{1}个" -f $pid,$private:当前福报数
& 'k_写log.ps1' -被写入的log内容 $private:temp995
#$DebugPreference = 'Continue'
if ($DebugPreference -eq 'Continue')
{
foreach ($i in (Get-RSJob))
{
$private:temp994 = "线程id:{0},完成状态:{1}" -f $i.InstanceID,$i.State
& 'k_写log.ps1' -被写入的log内容 $private:temp994
}
}
if ($script:等待1分钟)
{
Remove-Variable $script:等待1分钟
}
}
if ( ($private:现在.Minute % 9 -eq 0) -and ($private:现在.Second -gt 51) )
{
Write-Verbose '开始运行 .net 垃圾回收'
[System.GC]::Collect()
[System.GC]::WaitForPendingFinalizers()
$private:本进程_内的最大线程数_已经超过 = $True
}
}
exit 0
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
PowerShell
1
https://gitee.com/qmy2021/kasini3000.git
git@gitee.com:qmy2021/kasini3000.git
qmy2021
kasini3000
kasini3000
master

搜索帮助