MultiProcessing Pool не выполняет функцию - PullRequest
1 голос
/ 10 июля 2019

Я имел дело с этим в течение последних 5 часов, и я не знаю, что я делаю неправильно. Он просто печатает «Running pool ...», но, похоже, не выполняет функцию. Он не выдает никаких ошибок, он просто продолжает работать.

conn = pymysql.connect(host, user=user,port=port,passwd=password, db=dbname)

SQL = 'SELECT * FROM Clean_SBIR LIMIT {}, 20000'

def process_data(offset):
    print('Offset original: ',offset)
    offset = offset * 20000
    print('Actual offset: ',offset)
    df = pd.read_sql((SQL).format(offset), conn)
    print(offset)
    return len(df)

if __name__ == "__main__":
    with Pool(4) as pool:
        print('Running pool...')

        result = pool.apply_async(process_data, [1,2,3])
        print(result.get())
        print(pool.map(process_data, [1,2,3]))
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...