Category: Многопоточность

27
Сен
2022

Получить строку из файла ресурсов

Доброго времени суток!
Пишу клиент серверное приложение, используя систему контроля версий. Чтобы ненароком не выгрузить ничего лишнего, использую файл ресурсов в котором храню String записи для конфигов(пароли, юзера, адреса и т.д.). Как …

14
Сен
2022

Что означает n-канальный кеш L1/L2..?

Что означает n-канальный кеш L1/L2.. ? Иными словами, что такое каналы кеша, и на что они влияют. Так же интересно, сколько параллельных обращений к кешу L1 может делать одно ядро. То-есть, если я хочу сделать атомарное чтение из 2 строк …

12
Сен
2022

Необходимо ли синхронизировать методы классов, которые не имеют состояния?

Необходимо ли синхронизировать методы классов, которые не имеют состояния? Например, у меня есть класс:
@Slf4j
public class SomeServiceImpl implements SomeServiceService {

@Setter
private SomeDao someDao;

@Override
public…

26
Авг
2022

Как распределить вычисления функции для 50 датафреймов pandas по 8 ядрам процессора?

Последовательная реализация:
import pandas as pd
import numpy as np

np.random.seed(0)
a = {} # Словарь для датафреймов

def func(dataset,prm):
dataset[‘func’] = dataset.quantile(prm)

for i in range(50): # Создаю 50 случайных датафрей…

22
Авг
2022

Python Threading многопоточность которая не получилась

Суть приложухи – находить определения слов и картинки из гугла добавляя их в веб-страницу для пущей красоты.
Проблема вот какая.
Соответственно когда мы жмякаем кнопку, то в интернет должны полететь запросы на создание библиотеки.
Но на да…

21
Авг
2022

Подскажите с реализацией обработки запроса с заменой обработчика по истечении определенного времени?

У меня есть flask-приложение, которое принимает запрос, выполняет на его основе функцию и отдает пользователю ее результат. Мне нужно сделать так, чтобы если функция не вернула результат в течение, допустим, пяти секунд после поступления з…

16
Авг
2022

Как заставить работать асинхронные функции в потоке PyQt5

Господа, подскажите, как сделать так, что бы асинхронная функция заработала в потоке PyQt5.
from PyQt5 import QtCore, QtWidgets
import asyncio
import logging
from datetime import datetime
from ocpp.routing import on
from ocpp.v16 import Ch…

11
Авг
2022

Как применить функцию к набору датасетов pandas используя все ядра машины?

Есть долговыполняемая функция func, которую нужно применить к набору датасетов pandas (лежат в словаре) используя все ядра машины.
Сейчас это делается последовательно через цикл. Грузит машину на 5%, считает медленно:
for name in city_name…

07
Авг
2022

Как принимать данные с двух TCP портов?

У меня есть код которые принимает данные на порт 9090 и пишет эти данные в MYSQL. Как сделать чтобы можно было получать данные одновременно с порта 9090 и 9091? Данные с каждого порта должны записываться в разные таблицы. Например с порта …

06
Авг
2022

Как остановить дополнительный поток нажатием кнопки?

Необходимо помощь в решении следующей проблемы:
На главном окне есть кнопка (pushButton_2), которая должна останавливать дополнительный поток. Но она не работает.
Не могу понять, что я делаю не так. Прошу подсказать как решить данную пробл…

05
Авг
2022

Почему нельзя запустить выполнение программы просто через вызов метода start()? Почему нужно писать именно myTgread.thrd.start()?

public class MyThread implements Runnable{
Thread thrd;
TickTock ttob;

MyThread(String name, TickTock tt){
thrd = new Thread(this, name);
this.ttob = tt;
}
public static MyThread createAndStart(String n…

30
Июл
2022

Как избавиться от зависания GUI программы при обработке запросов?

Есть программа в которую через GUI передается ссылка, прога ее берет и делает некоторые манипуляции, отправляет запросы и т.д. и вот пока она это делает весь GUI программы полностью зависает. Я еще новичок, знаю что то про async await и mu…

21
Июл
2022

Реализация QProgressBar в потоке

Задача: из первого приложения (модуль m1.py) по кнопке вызывается второе приложение (модуль otv.py), в процессе выполнения которого, в statusBarпервого приложения (m1.py), отображается шкала ProgressBar.
Функционал в принципе работает, но…

19
Июл
2022

Сделал задачу на Multithreading.Посмотрите что можно доработать и укажите ошибки если они есть

Я недавно изучаю Java и хотел бы пресекать глупые ошибки на ходу. Поэтому по возможности, оцените код.
Задача была такова ->
1:Есть транспортные корабли, которые подплывают к туннели и далее плывут к причалам для погрузки разного рода т…

19
Июл
2022

Запуск несколько ассинхронных функций вместе на python

День добрый! Задача состоит в том, чтобы запустить несколько асинхронных функции разом.
Сейчас у меня только две функции: первая открывает сокет и непрерывно получает данные из этого соединения; вторая периодически делает запросы к другому…

18
Июл
2022

Как заставить поток реагировать на нажатие кнопки в другом потоке

Суть такова: требуется повесть на нажатие пробела звук удара, пауза на 500 мсек, звук реакции
В классе Sounds запускаю плееры. В главном потоке они работают, воспроизводят звук исправно.
Далее я запускаю поток, где проверяю булевую перемен…

18
Июл
2022

Как обработать большой массив без прерывания потока в JS, используя setTimeout?

Есть массив на +10000 элементов ссылок. Каждую итерацию ищется совпадает ли элемент по ссылке и удаляется, если да. В итоге выходит около 4 млн итераций и фризы.
Я пытался разбить массив на подмассивы и обрабатывать их через каждые 200 мил…

16
Июл
2022

Как ограничить время на ввод?

Хочу добиться того, чтобы программа перестала ждать ввода юзера, если он ничего не ввёл за 3 секунды, и код после считывания scanner начал исполняться. Но метод scanner.close() почему-то не работает здесь. Как исправить/реализовать иначе?

12
Июл
2022

Как использовать основной Spring Context для асинхронного метода?

Имеется приложение на Spring Boot-стеке. В приложении есть асинхронный метод, который на фоне должен выполнять действия с авторизованным пользователем, но так как асинхронный метод использует другой контекст, то авторизованного пользовател…

10
Июл
2022

Отложенное завершение ответа на запрос по другому событию (Python + Flask)

Пишу веб-сервер на Flask. Вот краткое описание задачи:
Есть два стула роута: /wait и /done
При запросе на /wait ответ не должен приходить до тех пор, пока не будет сделан запрос на /done.
Из-за того, что запросов на /wait могло быть за это…

07
Июл
2022

Как запустить функцию async из другого файла .py в отдельном потоке?

Есть код asyncio. Как его можно запустить из другого файла py, чтобы он работал в отдельном потоке?
from kucoin.client import Client
from kucoin.asyncio import KucoinSocketManager
import asyncio

api_key = ‘<api_key>’
api_secret = ‘&…

05
Июл
2022

Python – многопоточность и асинхронность

Делаю парсер на python смысл такой –

скрипту дают 10 ссылок (например)
дальше что бы не ждать долго пока он проверит все ссылки надо запустить этот скрипт в многопоточности
скрипт запускается несколько раз и проверяет одновременно ссылки