Tag: многопоточность

python не будет создавать поток?

Я мог бы пропустить что-то глупое, но ive запускал мой код в pythonwin, и он работает, но когда я запускаю его в командной строке, это уроды import time, thread def print_t(name, delay): while 1: time.sleep(delay) print name try: thread.start_new_thread(print_t,("First Message",1,)) thread.start_new_thread(print_t,("Second Message",2,)) except Exception as e: print e Unhandled exception in thread started by sys.excepthook […]

Как синхронизировать списки python?

У меня разные потоки, и после обработки они помещают данные в общий список. Есть ли что-нибудь построенное в python для списка или массив numpy, к которому можно получить доступ только по одному потоку. Во-вторых, если это не тот элегантный способ сделать это?

Переведите `thread.start_new_thread (…)` в новый API потоковой передачи

Когда я использую старый API-интерфейс thread Python, все работает нормально: thread.start_new_thread(main_func, args, kwargs) Но если я попытаюсь использовать новый API потоковой передачи, процесс, который запускает зависание потока, когда он должен выйти из него с помощью sys.exit(3) : threading.Thread(target=main_func, args=args, kwargs=kwargs).start() Как я могу перевести код в новый API потоковой передачи? Этот пример можно увидеть в […]

Django не блокирует электронную почту? Недостатки в threading.thread или подпроцесс?

У меня есть сайт django. Некоторые действия конечного пользователя отправляют электронную почту остальным пользователям в группе. Когда число пользователей становится равным> 20, оно может добавить 1-3 секунды к циклу запроса, что мне не нравится. Я хотел бы иметь возможность отправить электронное письмо из неблокирующей функции. Я знаю, что RabbitMQ и Celery в сочетании могут решить […]

Можно ли повторить итерацию словаря, модифицированного другим потоком, без привлечения исключений?

У меня есть словарь, который обновляется одним потоком, и в другом потоке я бы хотел перебрать его значения. Обычно я использую блокировку, но этот код очень критичен по производительности, и я хочу избежать этого, если это вообще возможно. Особенностью моего дела является то, что меня не волнует абсолютная правильность итератора; если он пропустил записи, которые […]

Выполнить 4 параллельных экземпляра сценария python в папке файлов данных

У нас есть папка с 50 файлами данных (последовательности ДНК следующего поколения), которые необходимо преобразовать, запустив скрипт python для каждого из них. Скрипт занимает 5 часов в файле, он однопоточный и в основном связан с ЦП (ядро процессора работает на 99% с минимальным дисковым IO). Поскольку у меня 4-ядерная машина, я бы хотел запустить 4 […]

Основные потоки в python

OK, код довольно простой. Поскольку я использую несколько потоков, и я хочу использовать общие переменные между ними, я использую глобальный. Почему код в ThreadClass иногда не выполняется, когда я нажимаю «C»? Я знаю, что это проблема параллелизма, но я не знаю, как это исправить. В последнее время я читаю семафоры и блокирую, но я точно […]

Концепции и инструменты, необходимые для масштабирования алгоритмов

Я хотел бы начать думать о том, как я могу расширить свои алгоритмы, которые я пишу для анализа данных, чтобы их можно было применять к произвольно большим наборам данных. Интересно, каковы соответствующие концепции (потоки, параллелизм, неизменные структуры данных, рекурсия) и инструменты (Hadoop / MapReduce, Terracota и Eucalyptus), чтобы это произошло, и как конкретно эти концепции […]

Как запустить фоновый процесс при постоянной проверке ввода – потоки?

У меня есть небольшие серверные и клиентские скрипты Python, где клиент отправляет строку, а сервер отвечает обратным. Когда клиент входит в строку завершения, клиент выходит, а затем сервер выходит из системы. Я хочу, чтобы процедура «получать, реверсировать и отправлять» сервера выполнялась в фоновом режиме, в то время как программа постоянно проверяет stdin для строки завершения. […]

запуск нескольких потоков в python

Я хочу, чтобы функция saveData из приведенного ниже кода выполнялась одновременно. Но вместо этого, после первого запуска saveData, я получил ошибку: Traceback (most recent call last): File "preProcess.py", line 70, in <module> run() File "preProcess.py", line 61, in run thread.start_new_thread(saveData(slice1, slice2, slice3, dset), ("Thread-" + str(i), 1, ) ) TypeError: first arg must be callable […]

 
Interesting Posts for Van-Lav

Переопределение других __rmul__ с помощью __mul__ вашего класса

TextField отсутствует в django.forms

Как jupyter может получить доступ к новому модулю tensorflow, установленному на правильном пути?

Сравнение символов в строке последовательно в Python

Выполнение загрузки файла с помощью python-oauth2

Сравнение экземпляров объектов SQLAlchemy для равноправия атрибутов

python django – страница не найдена ошибка (404) – статическая ошибка

Реализовать «Сохранить как» в диалоговом окне сохранения wxpython

«Ошибка: не удается найти установку программного обеспечения Oracle» При попытке установить cx_Oracle

Вставьте некоторую строку в заданную строку при заданном индексе в Python

Является ли numpy.transpose переупорядочиванием данных в памяти?

Got gdbm error: (13, 'Permission denied') – Несмотря на разрешение posix, похоже, ОК

Поверните 3D-изображения, чтобы сделать их 2D

MySQLdb Сохраненная процедура выхода Параметр не работает

Сбой сценария python после долгого времени

Python - лучший язык программирования в мире.