Главный процесс и поток чтооо? Или как передать аргумент в функцию класса Thread?

Question

[Александр]

Всем привет! Вот решил посмотреть в питоне на параллельные вычисления) задача сообщать когда переменная i == определённому значению
Но скрипт выполняет задуманное только на последнем elif
как это можно объяснить?
ниже привожу
код

from threading import Thread 
from time import sleep

for i in range(4):
    print(type(i))
    sleep(1)
    print(i)

def f(i):
    if int(i) == 1:
        print('i=',i)
        
    elif i == 2:
        print('i=',i)
        
    elif i == 3:
        print('i=', i)
        
t = Thread(target=f(i))
t.start()

Comments

[javedimka]

Последовательностью выполнения программы, к моменту запуска твоего потока i равна 3

[Александр]

javedimka: То есть процесс отдаёт данные после выполнения ? и если да то можно сделать так чтобы сработал 1 if 2 и 3 elif ? буду благодарен за разъяснения.

[Александр]

javedimka: И я почему-то думал что поток запускается одновременно с основным процессом для меня это как шок)

[Дмитрий]

Я не совсем понимаю причем тут вообще многопоточность

[javedimka]

sanya84: питон это скриптовый язык, выполнение идёт строчка за строчкой

[Александр]

Дмитрий: Я не совсем понимаю причем тут вообще многопоточность Запустите скрипт с итерацией for i in range(1000000): print(i) сколько это займёт времени ? мне допустим нужен контроль за ходом процесса извне

[Дмитрий]

sanya84 0:00:08.073375

[Александр]

Дмитрий: 0:00:08.073375 шикарно )

[Александр]

вот точно что я хотел увидеть

from threading import Thread 
from time import sleep

for i in range(4):
    print(type(i))
    print(i)
    sleep(1)
    def f(i):
        sleep(5)
        if int(i) == 1:
            print('i=',i)
        
        elif i == 2:
            print('i=',i)
        
        elif i == 3:
            print('i=', i)
            return
        
    t = Thread(target=f, args=(i,))
    t.start()
    t.join()

[Дмитрий]

Я если често очень плохо понимаю, что вы пытаетесь изобразить, но из того что я понял (надеюсь на то что я хоть что-то понял), у вас есть большой массив данных, который вы хотите обработать. Если это числовые данные, то советую использовать numpy, если это таблица забитая всем подряд, то pandas, функционал этих 2х библиотек покрывает практически все нужды в обработке данных, а из-за того что они написаны на C, то работают с приемлемой скоростью.

Если же у вас, например, лист с сыллками, которые необходимо спарсить в несколько потоков, то лучше использовать from multiprocessing.dummy import Pool, если что-то более сложное, то простым комментарием уже не обойтись и материала тянет на не одну статью, так что читайте доки, в частности, вас должны интересовать subprocess, threading и Queue

Answer 1

[Дмитрий]

Наверное, потому что вы в функцию передаете i равную 3м

И вызов потока неправильный
t = Thread(target=f, args=(i,))

Comments

[Александр]

Дмитрий я в комментариях добавил что я конкретно хочу могли бы вы посоветовать как это можно сделать ?

Answer 2

[Александр]

Вопрос решён ) надо было сделать так

from threading import Thread 
from time import sleep

for i in range(4):
    print(type(i))
    def f(i):
        if int(i) == 1:
            print('i=',i)
        
        elif i == 2:
            print('i=',i)
        
        elif i == 3:
            print('i=', i)
        
    t = Thread(target=f, args=(i,))
    t.start()
    sleep(1)
    print(i)

Comments

[javedimka]

Не надо так делать

[Дмитрий]

я хочу это развидеть...

[Александр]

javedimka: Поясните пожалуйста

[javedimka]

sanya84: в цикле функция создаётся 4 раза, новый поток создаётся 4 раза и запускается 4 раза. Если тебе убрать оттуда всю эту муть в две строчки с потоками и просто вместо них написать f(i) - получишь тот же самый результат, но уже просто 4 раза пересоздав функцию.
Советую скачать Лутца "Программируем на Python" последнее издание, открыть оглавление и перейти на модуль threading, он там почти в самом начале будет, читать не много, но хоть понятно будет как вообще с эти модулем можно и нужно работать