Вопросы с меткой [concurrency]
Руководство по использованию метки concurrency отсутствует.
132
вопроса
0
голосов
1
ответ
59
показов
Использование CompletableFuture блокирует главный поток
Я хочу использовать средства java.util.concurrent для организации асинхронности для долгих операций, которые возвращают значение. Я пытаюсь использовать для этого CompletableFuture. Сделал такой код ...
0
голосов
1
ответ
114
показов
Ограничение количество одновременных подключений с клиента в Golang GRPC
я новичок в GRPC и у меня стоит задача:
Необходимо написать сервис на Golang работающий по gRPC.
Сервис с функциями:
Принимает изображения от клиента и сохраняет их.
Выводит список загруженных файлов....
-2
голоса
1
ответ
79
показов
Посчитать сумму всех элементов двумерного массива используя Parallel Stream и Multithreading Java
Есть метод, который считает сумму всех элементов двумерного массива:
int sum2DArray(int[][] array) {
int sum = 0;
for (int[] ints : array) {
for (int number : ints) {
sum += number;...
-1
голос
1
ответ
82
показа
Коллеги объясните балбесу, почему? код не работает [закрыт]
Так значит проблема вот в чем,решил я решил порефакторить функцию ,а переписал в итоге все покрасивше))) но чего-то не заводится. почему не могу понять)))
Помогите))) и да вот репозиторий https://...
0
голосов
2
ответа
255
показов
Как запустить повторяющуюся блокирующую функцию в разных threads с помощью asyncio, python
Есть блокирующая функция, для примера возьмем:
def blockme(n):
x = random.random() * 2.0
time.sleep(x)
return n, x
(На самом деле мне нужны реквесты по API, но в контексте данного вопроса ...
0
голосов
1
ответ
100
показов
Правильная синхронизация с помощью Lock в Java
Доброго времени суток всем. Помогите, пожалуйста, советом. Нужно решить задачу. У меня есть класс с main методом:
public class ThreadExample {
public static void main(String [] args) {
Foo foo = ...
0
голосов
1
ответ
28
показов
Корректно ли отработает AtomicInteger?
В моём случае много потоков читают и записывают в одну переменную с проверкой на значение:
AtomicInteger value = new AtomicInteger(0);
public void threadMethod() {
if (value.get() < 30) {
...
1
голос
0
ответов
35
показов
В книге Thinking in Java 4th Edition дана программа, которая должна работать корректно, но мой код выбросил исключение. Почему?
В книге Thinking in Java 4th Edition дана программа, которая должна работать корректно, но несмотря на это при запуске ExplicitCriticalSection.main() выбросилось исключение. Почему?
Вот код ...
1
голос
2
ответа
118
показов
Конкурентные операции
Всем привет
Появилась пара заданий в учебном курсе, в которых требуется, например,сделать запись значений в мапу КОНКУРЕНТНО, возвести значения в квардрат КОНКУРЕНТНО и еще несколько в которых тоже ...
1
голос
1
ответ
725
показов
Можно ли выполнять таски в Celery по очереди?
Всем привет! У меня есть две таски download_and_send_youtube_video и clear_cache_youtube_video. Код:
@celery.task
def clear_cache_youtube_video(video_path: Path):
"""Clear YouTube ...
0
голосов
1
ответ
54
показа
Выполнение одной подпрограммы множеством потоков
столкнулся с проблемой вернее с тем как заставить множество потоков выполнять одну подпрограмму,насколько я понял в Perl для этого используется функция lock(), но при запуске кода:
use warnings;
use ...
0
голосов
1
ответ
135
показов
Не могу понять, о чём говорится в книге по Go
Фрагмент:
A goroutine is a task, whereas everything after the calling statement of a goroutine is a continuation. In the work-stealing strategy used by the Go scheduler, a (logical) processor that is ...
1
голос
1
ответ
294
показа
Как потоки кэшируют переменные или особенности работы volatile
Есть класс сущность с двумя полям (bool/int) и два потока, которые принимаю один и тот же объект этого класса.
class MyThread extends Thread {
Entity entity;
public MyThread(Entity entity) { ...
0
голосов
1
ответ
132
показа
Как обработать задачу и порождённые ею подзадачи с помощью ExecutorService?
Создаётся ExecutorService (допустим, на 10 потоков), который выполняет определённые задачи типа Callable<TaskResult>.
Объект класса TaskResult содержит результат выполнения задачи и список ...
0
голосов
1
ответ
69
показов
Как сделать систему завершения аукционов?
Проблема:
Есть аукционы с определенным временем завершения. В это время нужно проставить им статус и перестать принимать ставки. Взять оплату с покупателя и т.д. Как сделать завершение торгов?
Мое ...
2
голоса
2
ответа
134
показа
Насколько большая задержка при многопоточном доступе может быть при обновлении значения без volatile
Предыстория:
Есть объект(список объектов на самом деле), в одном из полей которого лежит HashMap.
Эта HashMap довольно часто перезаписывается (не значения в ней, а ссылка на объект - т.е. утрируя ...
2
голоса
1
ответ
80
показов
В чем смысл данных подходов при работе с потоками?
Сейчас я читаю книгу Williams A. C++ Concurrency in Action. Автор предлагает вызывать функцию join() в catch-ветке блока try-catch:
void some_func()
{
// Какая-то функция
}
void f()
{
std::...
0
голосов
0
ответов
66
показов
Корутины в использовании базы данных Kotlin
Я новичок в kotlin. Не совсем понимаю, как можно организовать concurrency в работе с базами данных SQLite, в частности корутины. Может ли кто-то, пожалуйста, обьяснить как это сделать?
0
голосов
1
ответ
328
показов
Поочередная запись потоками в файл
Всем привет, есть задание:
На вход передается целое число, больше 0, кратное 2 (n). Создается два потока, работающих
параллельно, каждый поток в цикле, считывает значение из файла out.txt увеличивает
...
0
голосов
1
ответ
638
показов
Как сделать методы потокобезопасными? Java
Допустим есть подобный сервис (SomeService), методы getObject() и setPojo() вызываются из RestController (Использую Spring). Вопрос, как сделать этот сервис потокобезопасным в многопоточной среде, ...
0
голосов
0
ответов
138
показов
Запуск потоков с интервалом (scheduleAtFixedRate(task, 1, 2, TimeUnit.SECONDS)) - SheduledExecutorService
Существует вот такой пример кода
public class ExecutorsRunnableRun {
public static void main(String[] args) {
ScheduledExecutorService scheduledExecutorService =
...
0
голосов
1
ответ
45
показов
Конкурентный доступ к кортежу в PostgreSQL
Есть таблица с счетом, на которую наваливается сразу много запросов, которые списывают с него средства:
create table account
(
id BIGSERIAL PRIMARY KEY,
volume BIGINT NOT NULL DEFAULT 0
);
...
0
голосов
0
ответов
42
показа
Вопрос об асинхронном методе [дубликат]
Есть вопрос по поводу асинхронной реализации метода, в каких случаях она выгодна? сейчас метод выполняется быстрее чем его реализация, а если синхронизировать с помощью семафор не вижу сильных отличий ...
0
голосов
0
ответов
60
показов
Почему код из Java Concurrency in Practice считается безопасным
читаю книгу Java Concurrency in Practice и один пример "безопасного" кода из 3 главы насторожил меня. В книге сказано, что использование volatile-переменных в связке с неизменяемыми ...
0
голосов
1
ответ
256
показов
Использование GCD в Swift
Всем привет! Никак не могу понять принцип работы многопоточности с GCD.
Я понимаю, что есть некая абстракция, названная "Потоки", в которой выполняются какие-то таски. Понимаю, что мы не управляем ...
0
голосов
0
ответов
777
показов
Обработка чисел из двух каналов и запись в третий на Go
Написал решение задачи на Go. Решение компилируется но на тестах выдаёт, что ожидает одно число из канала, а получает другое. Помогите разобраться, где ошибка.
Задание:
Необходимо написать функцию ...
0
голосов
1
ответ
115
показов
Как наиболее эффективно синхронизировать коллекцию?
Пишу RESTful сервис на Spring. Имеется класс CarProviderService, его зона ответственности - обновление ArrayList'а cars.
Раз в минуту с предоставлением актуального состояние этого листа другим ...
0
голосов
0
ответов
78
показов
Как корректно обновить значение в ConcurrentHashMap в многопоточной среде
У меня есть довольно простой класс, который собирает статистику по статусам.
public class Status {
private ConcurrentMap<String, AtomicInteger> statusesMap = new ConcurrentHashMap<>()...
0
голосов
0
ответов
61
показ
ReentrantLock не всегда справляется с блокировкой общего ресурса
Имеем задачу следующего содержания: есть порт, в порту - несколько доков, к которым причаливают корабли (у одного дока может стоять на погрузке/выгрузке только 1 корабль в какой-то момент времени). ...
0
голосов
1
ответ
202
показа
Почему нельзя "присоединить" поток std::thread дважды?
Скажем, мы хотим дожидаться одного потока в нескольких других, но по идее не можем этого сделать благодаря такому ограничению (из книги C++ Concurrency in Action):
При вызове join() очищается вся ...
0
голосов
1
ответ
75
показов
Запрос к БД внутри ConcurrentHashMap.compute()
Запрос к БД внутри ConcurrentHashMap.compute() при условии низкой нагрузки на map, насколько это корректно ? В java doc написано про метод compute
Some attempted update operations on this map by ...
0
голосов
0
ответов
156
показов
Проблема с CompletableFuture
Всем привет, у меня приложение отправляет письмо на почту, иногда почтовый сервер зависает и ничего не отдает, и соответственно приложение на отправку тоже, лечится после рестарта приложения. Чтобы ...
0
голосов
1
ответ
38
показов
Концепция Fail-Fast итераторов
Доброго времени суток.
Если я правильно понимаю, Fail-Fast итераторы сразу прекращают работу (обычно посредством генерации исключений), если обнаружат, что набор данных по которому они итерируются ...
2
голоса
1
ответ
358
показов
Многопоточный ping-pong. Использовать memory_order_acquire / memory_order_release или memory_order_relaxed?
Имеется код пинг-понга (использую MSVC 2017).
Вопрос: является ли он корректным? или нужно использовать memory_order_acquire и memory_order_release?
При запуске он работает нормально.
#include <...
0
голосов
1
ответ
675
показов
Golang. Как распараллелить обработку слайса, чтобы получить выигрышь в скорости?
Есть слайс, содержащий большое количество элементов, допустим 100000. Мне необходимо написать функцию, которая умножит каждый элемент данного слайcа на 2. Я хочу, чтобы эта функция работала ...
0
голосов
1
ответ
276
показов
Неблокирующий параллельный алгоритм поиска максимума и его индекса
Существует ли неблокирующий параллельный алгоритм поиска максимального элемента массива а также его индекса? Есть такая реализация,
AtomicInteger atomicMin = new AtomicInteger(99999);
AtomicInteger ...
1
голос
0
ответов
376
показов
Если бы ASP.NET Core был одно-поточен
Многопоточность
Согласно моему познанию ASP.NET Core и если сильно не углубляться в детали, то на сегодняшний день обработка HTTP-запросов на одноядерном процессоре происходит следующим образом:
...
0
голосов
1
ответ
511
показов
Swift barrier блокирование Work items
Из документации Apple:
async: execute work: work The work item to be invoked on the queue.
barrier: Work items submitted prior to the barrier execute to completion, at which point the barrier work ...
0
голосов
1
ответ
106
показов
Executors. Как прекращать работу потоков?
Я делаю некий таймер. При его запуске выполняется какая-то последовательность действий, после чего поток должен закрыться и не грузить дальнейшую работу программы. Как мне его адекватно остановиться, ...
1
голос
1
ответ
27
показов
Как вызвать InteraptedException для потоков ожидающий блокировку методом lockInterruptibly из java.util.concurrent.locks.Lock
Есть ли способ получить все потоки ожидающие блокировки и вызвать на них interrupt из критической области, потоком владеющим блокировкой ?
0
голосов
1
ответ
137
показов
Go concurrency и использование общей переменной
Изучая Go, придумал себе задачу. Есть некий URL вида https://host/id. На некоторых айдишниках есть контент, на некоторых возвращает сообщение о том, что нет ничего по такому айдишнику. Задача: чтобы ...
0
голосов
1
ответ
257
показов
Future и получение данных по мере их выполнения
Помогите разобраться пожалуйста.
Шлю запрос в базюки и получаю время выполнения запроса.
Ниже представлен метод в контроллере, в котором в теле запроса я передаю какой-то запрос. Создаю пул из 3 ...
2
голоса
1
ответ
904
показа
Потокобезопасный ArrayList
Пишу свою реализацию потокобезопасного эррэй листа на CAS-блокировках (не спрашивайте зачем). Столкнулся с некоторым непонятным мне поведением в процессе записи элементов в лист. Код реализации ...
1
голос
0
ответов
62
показа
Кэш для нагруженного веб приложения
Приложение отдает одинаковые данные клиентам. Например список стран. Я хочу сделать так, чтобы не нужно было постоянно дергать базу, а при первом запуске приложения считывать в кэш этот справочник и ...
0
голосов
1
ответ
384
показа
Конкурентная загрузка файлов через http.Client, golang
Прошу помочь разобраться с такой проблемой. Пробую получать файлы Get-запросом в нескольких горутинах:
type RemoteImages []RemoteImage
type RemoteImage struct {
Lang string `json:"lang"`
...
1
голос
2
ответа
32
показа
Видимость в фоновом потоке значения, измененного в главном потоке
В этом коде есть проблема: фоновый поток не остановится никогда. Почему это происходит? В книге объяснение такое: без синхронизации нет гарантированного времени, когда фоновый поток увидит измененное ...
0
голосов
0
ответов
39
показов
использование ConcurentBag при работе с БД
Как можно использовать ConcurrentBag при работе с БД? и в каких случаях это нужно. Большинство примеров рассмотрены с добавлением string/int значений. К коллекции применяются Linq-запросы, коллекция ...
0
голосов
1
ответ
131
показ
Многопоточный доступ к коллекции Java
Начал изучать многопоточность в Java и возник следующий вопрос: У меня есть некая коллекция, допустим map, которая содержит объекты Account c полем flot money = 100; Я хочу запустить 4 потока, которые ...
-2
голоса
2
ответа
259
показов
Невозможность асинхронного вызова recvfrom()
Вызов recvfrom() из вызванной асинхронно функции блокирует не только нить, в которой функция, но и вызывавший поток (возврат в него не происходит). Почему и как это обойти?
ps Это, если верно считаю,...
-7
голосов
3
ответа
353
показа
Конкурентное программирование. async с отложенным await. C#
Вот код, который работает, как и ожидалось:
async Task<int> Delay(int for_count)
{
lock (thisLock)
{
double result = double.MaxValue;
for (int i = 0; i < for_count; i+...