Вопросы с меткой [async-programming]
Руководство по использованию метки async-programming отсутствует.
94
вопроса
0
голосов
0
ответов
10
показов
Как реализовать вызов асинхронных функций по расписанию в python?
Ниже приведен рабочий код на python для вызова синхронных функций по расписанию, но требуется вызывать их ассинхронный аналог. Как правильно реализовать вызов асинхронных функций по расписанию ? Какая ...
1
голос
1
ответ
41
показ
Как запустить asyncio код отдельно от общего event loop'a?
Есть бот в телеграмме, который парсит сайт, на каждого пользователя создается по 40-60 тасков (для каждого элемента который надо обработать),с большим количеством пользователей бот начинает тормозить, ...
0
голосов
1
ответ
14
показов
Узнать удалённую/добавленную роль пользователю discord.py?
Я делаю лог-бота который выводит все логи.
Как узнать когда пользователю дали роль, и когда пользователю убрали роль?
Есть-ли по типу on_member_role_create или on_member_role_remove?
-4
голоса
1
ответ
33
показа
Создание программы по типу календарика с заметками [закрыт]
пишу программу для одной компании,суть программы заключается в бронировании столов по времени и дням (грубо говоря как календарь на телефоне с заметками) только преобразован в интерфейсе. Питон знаю,...
1
голос
1
ответ
26
показов
Бесконечные запросы на сервер
Запрашиваю с сервера список товаров,а потом через set получаю категории товаров по их свойствам.
Когда загружается страница,то все работает и ошибок никаких в консоли нет,но если подождать,то сайт ...
0
голосов
1
ответ
53
показа
Как в помощью Asyncio создать функцию постоянно выполняющуюся на фоне
Необходимо сделать цикл (как вариант библиотека Asyncio) который будет работать в фоне параллельно с работой основного кода. Этакая многопоточность.
Пример:
пользователь вводит цифры в программу, а ...
0
голосов
0
ответов
12
показов
Асинхронная отправка сообщений WCF
Реализовал метод асинхронной отправки сообщений клиентам, но он отправляет это сообщение абсолютно всем, в том числе и самому отправителю.
Как сделать так чтобы сообщение приходило всем кроме ...
0
голосов
1
ответ
33
показа
Как правильно асинхронно отправить запрос и обработать ответ?
Отправляю Post запрос, а затем его обрабатываю - десериализую и пересылаю ответ:
// Отправка запроса на API др. сервиса
string jsonRequest = JsonSerializer.Serialize(requestMessage);
...
0
голосов
1
ответ
152
показа
Закрытие asyncio loop
Всем привет!
import asyncio
import aiohttp
aut_token = ("token")
tasks = []
iter_flag = True
interval = 0
seq = 0
class WAPI:
async def receiver(WAPI_S):
async for msg in WAPI_S:...
0
голосов
0
ответов
17
показов
Привет! Сложный вопрос для меня: как записать данные приходящие одновременно на RESTful Web-сервер от трех клиентов в 3 разные файла Excel?
Есть сервер и три смартфона, которые ПОЧТИ ОДНОВРЕМЕНО отсылают свои данные (координаты, время, id) на этот сервер. Как мне записывать эти данные в разные файлы, которые имеют названия по своему id ...
0
голосов
0
ответов
104
показа
Как использовать boost Asio в асинхронном режиме в несколько потоков?
Как использовать boost Asio в асинхронном режиме в несколько потоков? Может я был невнимателен, но насколько я понял, у всех потоков может быть единый io_context и в каждом потоке просто необходимо ...
0
голосов
0
ответов
17
показов
Путаница с сигнатурами хэндлеров асинхронных функций boost.Asio
Не могу понять, почему я не могу вызывать функцию async_accept с параметрами, указанными в main в коде ниже. Я знаю что сигнатура хэндлера async_accept следующая: void (*handler)(const boost::system::...
0
голосов
1
ответ
28
показов
Как объявить функцию, которая будут принимать хэндлер, аналогичный асинхронным функциям boost.asio?
Я хочу написать метод, который будет инкопсулировать в себе некоторую логику работы с boost.Asio, но чтоб в этот метод можно было передать хэндлер, который, внутри метода, можно передать в асинхронную ...
1
голос
1
ответ
828
показов
Не работает приветственное сообщение discord.py
@client.event
async def on_member_join(member):
channelsadg = client.get_channel(725755517066018829) #Where ID is your welcome channel's ID
await channelsadg.send(f'Привет, {member}! Ты попал ...
0
голосов
2
ответа
102
показа
Как перенести полученный DeepLink (FB SDK) из метода onDeferredAppLinkDataFetched в переменную активности?
Всем привет! Я использую глубокие ссылки из FB (обычные и отложенные), ловлю их в методе onDeferredAppLinkDataFetched, в логах все выводиться - супер! Теперь я хочу поработать с этой глубокой ссылкой, ...
0
голосов
1
ответ
73
показа
Почему не стартует корутина при onStart() активити?
Такая ситуация: мне нужно сохранять данные в Firebase. Я это делаю фоново с помощью корутины. Сейчас она запускается в методы onCreate(). А мне нужно сделать так, чтобы при onStop() она заканчивала ...
2
голоса
3
ответа
190
показов
Синхронный вызов vs await Task.Run() для CPU-bound операций .Net
Многие рекомендуют, как например здесь, использовать Task.Run() для Cpu-bound операций.
В статье по ссылке написано, что Task.Run() стоит использовать если:
мы используем WinForms и хотим оставить ...
1
голос
1
ответ
31
показ
Как происходит возврат значения из функции
Всем привет, вопрос небольшой:
class UserRepository {
private val webservice: Webservice = TODO()
fun getUser(userId: String): LiveData<User> {
val data = MutableLiveData<User>()
...
1
голос
1
ответ
29
показов
Использование Memcache и Mysql вместе
Использую модули mysql2 и memcached
Хочу делать запросы в бд если нужное не найдено в Memcache, но так как запросы асинхронные приходится использовать callback для mysql, но тогда код внутри не ...
0
голосов
0
ответов
79
показов
Java эквивалент C # async/await?
Обычно я пишу на C#, но иногда я разрабатываю приложения на Java. Мне интересно, есть ли какой-нибудь Java-эквивалент C# async / await? Как такое написать в Java:
async Task<int> ...
0
голосов
1
ответ
92
показа
Последовательное выполнение функций в объекте массивов js
не получается выполнить последовательное выполнение функций в объекте массивов. Для примера у меня есть объект:
{ string1: "string1",
string2: "string2",
string3: "string3"}
и есть 2 функции ...
0
голосов
1
ответ
105
показов
websocket асинхронные запросы клиентов к одной async функции сервера
пишу систему сбора данных, использую WebSoket на Node.JS.
Клиенты обращаются к серверу, сервер в свою очередь, запрашивает с помощью асинхронной функции данные от "железки" (т.е. надо подождать ...
0
голосов
1
ответ
187
показов
Промис не дожидается ответа из асинхронной функции [дубликат]
Я новичок в JS и еще учусь. Решил попробовать написать расширение для Chrome.
Расширение принимает список из ключевых слов и после этого цикл должен формировать из каждого слова ссылку и создавать ...
1
голос
1
ответ
40
показов
Vuex action - записать ответ промиса в переменную
Есть экшн.
messageLastDate: (context, state) => {
axios.get('api/messageLastDate').then(response => {
let lastMessage = response.data
});
...
1
голос
3
ответа
50
показов
Вызов неопределенного количества функций
Доброго всем времени суток cтолкнулся с таким вопросом - создать функцию в которой первый параметр временной интервал (в секундах), а следующие параметры (неопределенное количество) будут являться ...
0
голосов
0
ответов
37
показов
Асинхронные запросы на сервер с ID
Стоит такая задача.
Есть сервер, доступ к нему осуществляется по IP адресу через HTTP, он запрашивает логин-пароль.
Клиент создает запрос, отправляет JSON объект с этим запросом, сервер обрабатывает ...
3
голоса
2
ответа
349
показов
Останавливает ли намертво QEventLoop поток выполнения операционной системы?
Предположим, что мне нужно выполнять чтение данных из файла с некоторым интервалом времени, не используя QFileSystemWatcher с сигналами для мониторинга размера и тд. В интернете наткнулся на подобное ...
1
голос
0
ответов
181
показ
нагрузочный тест на java
Есть сервер, есть тестовый клиент. Клиент посылает один запрос и получает один ответ. Необходимо переделать клиент таким образом, чтобы он делал нагрузочное тестирование.
Что надо сделать:
1) ...
5
голосов
3
ответа
6k
показов
Task.Run - антипаттерн async/await? C#
Недавно прочитал статью на хабре (upd: из комментов понял, что нужно прицепить цитату, по которой далее вопрос)
Как только код доходит до метода Task.Run(), достаётся другой поток из пула потоков и ...
-2
голоса
2
ответа
165
показов
Невозможность асинхронного вызова recvfrom()
Вызов recvfrom() из вызванной асинхронно функции блокирует не только нить, в которой функция, но и вызывавший поток (возврат в него не происходит). Почему и как это обойти?
ps Это, если верно считаю,...
1
голос
1
ответ
251
показ
Аналоги Netty для c++
Некоторое время использовал фреймворк Netty для создания асинхронного неблокирующего сервера. Сейчас подумываю перекатываться на c++, есть ли аналоги Netty для c++? Желательно не медленнее Netty.
2
голоса
0
ответов
46
показов
Аналог await для libuv
Сейчас await сделал вот так
void rr_await(rr_context *c){
while (uv_run(c->handle->loop, UV_RUN_ONCE) && c->ok==0);
}
Проверяем флаг в переменной каждый цикл. rr_context - ...
0
голосов
0
ответов
51
показ
Какой вариант реализации метода приоритетнее? [дубликат]
Есть некий клиент, под капотом у которого HttpClient
public class Client
{
private HttpClient httpClient;
private const string BaseAddress = "https://api.domain.com/";
public Client(...
0
голосов
1
ответ
88
показов
Не могу найти пример Call back'а из асинхронной функции
Меня интересует возврат значения из асинхронной функции не используя метод фьючерса .get(),что бы была возможность не дожидаться завершения асинхронной функции.
0
голосов
0
ответов
48
показов
Событийно ориентированное и асинхронное программирование
В чем разница между событийно ориентированным и асинхронным программированием? Если можно, на каком нибудь контрастном примере.
0
голосов
0
ответов
102
показа
Асинхронное считывание файла в Linux
Я хочу получить следующую функциональность
Открываю файл, вызываю функцию асинхронного чтения и делаю дальше свои дела (т.е. код после вызова этой функции выполняется). Дальше ядро, выполнив чтение ...
-1
голос
1
ответ
203
показа
C#: Запуск Tasks в цикле [дубликат]
Код:
Task<RequestBodyModelDC>[] relatedObjectMapping = new Task<RequestBodyModelDC>[fields.Columns.Count];
for (int i = 0; i < relatedObjectMapping.Count(); i++)
{
...
0
голосов
1
ответ
173
показа
Готовность других задач в asyncio
Я начал изучать асинхронную разработку в Python 3 и столкнулся с такой дилеммой:
Допустим, у меня есть задачи, и внутри я проверяю, что если эта задача будет выполнятся "долго", то я её "откладываю" (...
0
голосов
1
ответ
217
показов
Python асинхронные запросы через ZeroMQ
Есть блокирующий метод, который должен c помощью либы ZeroMQ сделать несколько асинхронных запросов каждому слушателям из списка, после отправки сообщения, дождаться первого ответа от любого из..., ...
0
голосов
1
ответ
104
показа
Как ожидать результат выполнения асинхронного кода?
Есть такой клас
static public class Methods
{
static Customer[] customers;
public static Customer[] GetCustomers(string login, string password)
{
AtmisOrderServiceSoapClient ...
0
голосов
0
ответов
53
показа
Асинхронное чтение данных с сервера
Какой самый удобный способ (С++) для асинхронного чтения постоянно приходящих с сервера данных? Платформа Windows.
Если есть возможность, хотелось бы увидеть схематичный пример (или линк на ...
0
голосов
1
ответ
21
показ
Непонятный WritePendingException
Есть сервер, на Java, работающий на асинхронных сокетах. Код сервера, примерно, такой
class ClientHandler implements CompletionHandler<Integer, ByteBuffer> {
private final ...
0
голосов
1
ответ
122
показа
Non blocking в Web flux
Какая разница между blocking и Non blocking, ведь в non blocking запросе должен ведь какой то поток прослушивать ответ от сервера.
Не понимаю эту идею, какая будет польза от web flux?
1
голос
0
ответов
57
показов
Как превратить функцию, которая возвращает значение через callback, в future?
Предположим у нас есть некоторая функция (и её нельзя менять):
void action(Consumer<Result> callback);
Или даже такая:
void action(Consumer<Result> onSuccess, Consumer<Throwable> ...
2
голоса
0
ответов
53
показа
autobahn.twisted.websocket opening handshake error 400
Кто-нибудь работал с API Bitfinex? Пытаюсь подписаться на канал, получаю ошибку. Понимаю, что проблема в передаваемых данных скорее всего. И не могу понять, в чем именно.
Код:
from autobahn....
1
голос
1
ответ
64
показа
Асинхронная функция в цикле
Необходимо сделать выборку всех пользователей в базе данных (использую Firestore), записать в массив и этот массив в качестве результата передать в основной код. При всём этом у пользователя может ...
2
голоса
1
ответ
183
показа
socket.io событие эмитится слишком много раз
Задача:
Получить имена пользователей
Проблема:
Для начала я добавляю макеты этих диалогов - первая строчка цикла.
Потом я отправляю JSONObject через этот emit (все работает!)
Далее, по логике, ...
1
голос
1
ответ
743
показа
Что должно быть, если вызвать async-функцию без await?
Разбираюсь с написанием кода с новыми async/await возможностями. Мне не совсем понятен следующий нюанс. Предположим есть async-функция f1() и что если мы возьмем и вызовем эту функцию в функции f2() ...
0
голосов
1
ответ
116
показов
Как вызвать Promise.all для неопределенного количества функции в Node.js
Есть следующий код:
return Promise.all([asyncFunc(var1), asyncFunc(var2)]);
А надо что то вроде:
var arrayToAsynCall = [];
for(val in params){
arrayToAsynCall.push(asyncFunc(val));
}
.............
1
голос
0
ответов
274
показа
RuntimeError: IOLoop is already running
@gen.coroutine
def _get(self, account, data_id):
"method implements getting data from db"
query = "SELECT data FROM configuration WHERE name = '{0}' ;".format(account)
cursor = yield self....