Версия 6.17 Многопроцессорность Python

enableconsolepython(1, 1, 50, 50, 800, 200);

int Kol_Process=20;

//Запускаем процессы Python
for (int n=0; n<Kol_Process; n++)
{
if (runpython(ARRAY)<1){messagebox ("Не удалось запустить Python"); goto er;}
}


for (n=0; n<Kol_Process; n++)
{
selectpython(n);//Переключаем процессы Python и запускаем в них скрипт
//Запускаем скрипт в НЕ блокирующем режиме
__python
import time
a=0
for i in range(10):
(4пробела)a=a+1
(4пробела)time.sleep(0.1)

print ('finished')
__end_python
}
//////////////

int time=gettime();//Засекаем время

new int rez[Kol_Process];
int t=0;
string CheckAPython;
loop()//Замкнутый цикл в котором проверяем ответы от Python
{
for (n=0; n<Kol_Process; n++)//Перечисляем запущенные процессы Python
{
selectpython(n);//Переключаем процессы Python
if (getpython()=="finished")//Проверяем ответы от Python когда закончит
{
//messagebox ("Python "+format (n)+" закончил = "+sendgetpython("print (a)")); //Сообщение когда заканчивают. Может быть по разному кто первый
rez[t]=formatsn(sendgetpython("print (a)"));//Записываем полученный результат (в данном случае переменную a Python)
t++;//Увеличиваем счетчик отработанных процессов Python
if (t==Kol_Process) goto ex;//Если отработали все процессы выходим с цикла
}
}
sleep(10);
}
ex:;

string S="";
for (n=0; n<Kol_Process; n++)
{
S=S+"Python "+format(n)+" закончил = " + format(rez[0])+"^r^n";
}
S=S+"Всего было "+format(10*Kol_Process)+" операций с задержкой между ними в 0.1 секунду^r^n";
S=S+"Затрачено времени "+format(gettime()-time)+" мсек";
messagebox (S);

closepython();//Завершием работу всех процессов Python
er:;
disableconsolepython();

enableconsolepython(1, 1, 50, 50, 800, 200);

//Запускаем процесс Python
if (runpython()==0){messagebox ("Не удалось запустить Python"); goto er;}

//Запускаем скрипт в НЕ блокирующем режиме
__python
import time
a=0
for i in range(200):
(4пробела)a=a+1
(4пробела)time.sleep(0.1)

print ('finished')
__end_python
}
//////////////

int time=gettime();//Засекаем время

int rez;
string CheckAPython;
loop()//Замкнутый цикл в котором проверяем ответы от Python
{
if (getpython()=="finished")//Проверяем ответы от Python когда закончит
{
//messagebox ("Python "+format (n)+" закончил = "+sendgetpython("print (a)")); //Сообщение когда заканчивают. Может быть по разному кто первый
rez=formatsn(sendgetpython("print (a)"));//Записываем полученный результат (в данном случае переменную a Python)
goto ex;//Если отработали два процесса выходим с цикла
}
sleep(100);
}
ex:;

string S="";
S=S+"Python закончил = " + format(rez)+"^r^n";
S=S+"Всего было 200 операций с задержкой между ними в 0.1 секунду^r^n";
S=S+"Затрачено времени "+format(gettime()-time)+" мсек";
messagebox (S);

closepython();//Завершием работу всех процессов Python
er:;
disableconsolepython();