guanjihuan/guanjihuan.com
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update parallel.py

Browse Source
This commit is contained in:
guanjihuan
2023-02-24 07:05:21 +08:00
parent 3114bc87d4
commit 5206edc5c1
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
language_learning/2023.02.21_parallel_python_manually/parallel.py
View File

@@ -11,13 +11,15 @@ index = 0
for parameter_str in parameter_str_array: for parameter_str in parameter_str_array:
index += 1 index += 1
# 以下处理代码文件【说明：linux系统下复制用cp，windows系统下复制用copy】 # 以下处理代码文件
# 说明：linux系统下复制用cp，windows系统下复制用copy
os.system('cp a.py a'+str(index)+'.py') # 复制python代码文件 os.system('cp a.py a'+str(index)+'.py') # 复制python代码文件
with open('a'+str(index)+'.py', 'r') as f: # 读取 with open('a'+str(index)+'.py', 'r') as f: # 读取
content = f.read() content = f.read()
old_str = 'parameter_array_labeled_for_replacement = []' old_str = 'parameter_array_labeled_for_replacement = []'
new_str = 'parameter_array_labeled_for_replacement = ' + parameter_str new_str = 'parameter_array_labeled_for_replacement = ' + parameter_str
content = content.replace(old_str, new_str) content = content.replace(old_str, new_str)
# 如果程序需要将数据写入文件，除了需要替代参数，还需要替代文件名，方法和以上相同
with open('a'+str(index)+'.py', 'w') as f: # 写入 with open('a'+str(index)+'.py', 'w') as f: # 写入
f.write(content) f.write(content)
@@ -32,4 +34,4 @@ for parameter_str in parameter_str_array:
f.write(content) f.write(content)
# 提交任务 # 提交任务
os.system('qsub a'+str(index)+'.sh') # 提交任务 os.system('qsub a'+str(index)+'.sh')