Описание тега python-multithreading
Многопоточность python относится к тому, как разделить работу на несколько потоков выполнения в Python.
1
ответ
Получение asyncio для запуска функции по порядку (Python 3)
Вот простой пример использования asyncio распечатать цифры от 0 до 9. Проблема: иногда код печатает числа от 0 до 7, затем печатает 9, а затем 8. Особенно, когда вы устанавливаете ThreadPoolExecutor на меньшее число, например 4 или 5. 0 1 2 3 4 5 6 …
24 апр '18 в 14:15
2
ответа
Бесконечный "фоновый" цикл для обработчика Tornado WebSockets
Я пытаюсь создать сервер WebSocket, используя Tornado. То, что я хотел бы сделать, это выполнить определенную команду, которая будет отправлять сообщение для каждого цикла IOLoop. Чтобы было понятнее; скажем, у меня есть следующий обработчик WebSock…
12 фев '14 в 15:10
1
ответ
Python: Что если мы вызовем thread.start() и оставим его без соединения или закрытия?
Когда я создаю новый поток из потоков. Вот так: def hello(): print ('hello') t = threading.Thread(target=hello) t1.start() Если бы я создавал все больше и больше таких потоков, у меня не хватило бы памяти или потоков для использования? Можно ли так …
19 апр '18 в 02:58
1
ответ
Каково значение condition.notify() в поточном модуле python?
Поэтому я использую условие Python из модуля потоков: from threading import Thread, Condition condition = Condition() У меня есть класс Producer (подкласс Thread), который, по существу, в цикле for добавляет элементы в очередь до тех пор, пока очере…
20 сен '17 в 18:16
1
ответ
Вкладки Python Threading и tkinter.tix.NoteBook недоступны после первой открытой вкладки
В следующем примере я не могу писать на другие вкладки, кроме открытой по умолчанию вкладки "Журнал": #!/usr/bin/python import os, sys import threading import time from itertools import count import tkinter from tkinter import * from tkinter import …
09 июл '11 в 14:10
1
ответ
Зависание многопоточного приложения python
Я написал программу, которую я использую для сравнения базы данных mongodb, работающей в условиях многопоточной массовой записи. Проблема в том, что программа зависает и не завершает выполнение. Я совершенно уверен, что проблема заключается в записи…
23 мар '18 в 13:12
1
ответ
Общий обработчик исключений для многопоточного приложения Python
Можно ли перехватывать исключения для всех потоков приложения Python с помощью общего обработчика исключений? Рассмотрим следующий пример. Я хотел бы поймать CTRL+C из основного потока, но иногда он попадает в один из рабочих потоков, который не зав…
14 апр '13 в 11:26
3
ответа
Выполнение Python-паузы
Есть ли способ "приостановить" основной поток Python приложения? У меня есть код, который запускает два потока class start(): def __init__(self): Thread1= functions.threads.Thread1() Thread1.setDaemon(True) Thread1.start() Thread2= functions.threads…
05 окт '11 в 12:07
2
ответа
Как изменить значение аргумента в запущенном потоке в Python
Как изменить параметр функции, выполняющейся в бесконечном цикле в потоке (python)? Я новичок в потоках и Python, но это то, что я хочу сделать (упрощенно), class myThread (threading.Thread): def __init__(self, i): threading.Thread.__init__(self) de…
24 май '17 в 18:53
1
ответ
Подпроцесс умирает, когда поток умирает
У меня есть программа, которая запускает таймеры Python для запуска подпроцессов. Эти подпроцессы должны быть прекращены, как только моя программа будет завершена или уничтожена. Чтобы сделать это, я использую "prctl hack", который устанавливает, ка…
13 сен '17 в 11:05
0
ответов
Использование TensorFlow вместе с пулом параллельных процессов
Мы интегрируем TensorFlow в более крупное приложение. Одним из требований является то, что мы можем загружать и выполнять существующие модели с диска и запускать их в главном потоке. Обучение может выполняться асинхронно в другом потоке. Если мы вып…
10 ноя '17 в 08:22
1
ответ
Многопоточный сканер в python
Я пытаюсь реализовать многопоточный сканер, который принимает начальный URL и ищет ссылки в этой ссылке, отображает каждую ссылку и одновременно ищет ссылки в каждой ссылке. Это мой код import urllib.request, re, threading, csv from queue import Que…
13 ноя '15 в 15:18
0
ответов
Многопоточное приложение ssh на python
У меня есть приложение, которое я собрал, чтобы попытаться создать 3 потока и ssh на сервере одновременно. Я написал заведомо оскорбительное заявление, которое, как я знаю, является неправильным, и которое я ищу для получения руководства, для достиж…
28 июн '12 в 01:25
3
ответа
python: Mac OS X. ошибка malloc. освобожденный указатель не был выделен. прерывание ловушки 6
Я использую многопоточный скрипт на Python. он будет сканировать сеть и вставлять / обновлять в mysql. вот мой код mythread.py import threading import time class MyThread (threading.Thread): def __init__(self, threadID, threadname, q): threading.Thr…
14 июл '14 в 14:19
2
ответа
Несколько экземпляров scipy.integrate.ode
Я хотел бы использовать экземпляры scipy.integrate.ode (или scipy.integrate.odeint) в нескольких потоках (по одному на каждое ядро ЦП) для решения нескольких IVP одновременно. Однако в документации сказано: "Этот интегратор не является повторно вх…
15 дек '15 в 14:23
1
ответ
Удалите ненужные символы из файла JSON, используя разные потоки (Python)
В моем файле Python я создал класс под названием Download, Код, в котором находится класс: import requests, json, os, pytube, threading class Download: def __init__(self, url, json=False, get=False, post=False, put=False, unwanted="", wanted="", unw…
12 ноя '17 в 17:06
0
ответов
Я пытаюсь использовать параллельные фьючерсы для потоков, но кажется, что некоторые фьючерсы не возвращаются, они продолжают работать бесконечно
def parallelize_task_by_thread(func, iterable, workers=4): with ThreadPoolExecutor(max_workers=workers) as executor: future_to_url = {executor.submit(func, i): i for i in iterable} result = [] for future in concurrent.futures.as_completed(future_to_…
05 авг '18 в 08:03
0
ответов
Является ли tkinter в python 3.4.4 потокобезопасным?
Следующий код ведет себя по-разному в Python 2.7.11 (после установки future) и 3.4.4 import tkinter as tk from tkinter import ttk import threading from time import sleep def do_something_slow(): sleep(5) progressbar.grid_remove() app = tk.Tk() progr…
26 окт '16 в 11:08
1
ответ
Завершение основного потока из дочернего потока
У меня есть поток с графическим интерфейсом и основной поток. После закрытия окна у меня есть метод, вызываемый внутри потока GUI. Я хотел бы распространить это на главный поток, чтобы закончить свою работу. Основной поток выполняет несколько шагов,…
25 мар '18 в 21:17
1
ответ
Проблемы с Python Threading и кодом в целом
Учитывая следующий код Python3, с потоками: class main: def __init__(self): self.text = open(os.getcwd()+"/FileScanLogs.txt", "a+") self.hashlist = queue.Queue() self.filelist = queue.Queue() self.top = '/home/' for y in range(12): self.u = threadin…
08 июл '17 в 10:27