|
@@ -12,6 +12,7 @@ import pymysql
|
|
|
import multiprocessing as mp
|
|
import multiprocessing as mp
|
|
|
import math
|
|
import math
|
|
|
import psutil
|
|
import psutil
|
|
|
|
|
+import datetime
|
|
|
from apscheduler.schedulers.blocking import BlockingScheduler
|
|
from apscheduler.schedulers.blocking import BlockingScheduler
|
|
|
import sys
|
|
import sys
|
|
|
import gc
|
|
import gc
|
|
@@ -355,7 +356,7 @@ if __name__ == '__main__':
|
|
|
mp.freeze_support()
|
|
mp.freeze_support()
|
|
|
print('cpu_count =', mp.cpu_count())
|
|
print('cpu_count =', mp.cpu_count())
|
|
|
pus = psutil.Process()
|
|
pus = psutil.Process()
|
|
|
- pus.cpu_affinity([6, 7])
|
|
|
|
|
|
|
+ pus.cpu_affinity([12, 13, 14, 15, 16, 17])
|
|
|
|
|
|
|
|
# 指定客户端所在路径
|
|
# 指定客户端所在路径
|
|
|
path = r'c:\\qmt\\userdata_mini'
|
|
path = r'c:\\qmt\\userdata_mini'
|
