Вопросы с меткой [concurrency]

Руководство по использованию метки отсутствует.

Фильтрация
Сортировка
Метки
0 голосов
1 ответ
59 показов

Использование CompletableFuture блокирует главный поток

Я хочу использовать средства java.util.concurrent для организации асинхронности для долгих операций, которые возвращают значение. Я пытаюсь использовать для этого CompletableFuture. Сделал такой код ...
faritowich's user avatar
0 голосов
1 ответ
114 показов

Ограничение количество одновременных подключений с клиента в Golang GRPC

я новичок в GRPC и у меня стоит задача: Необходимо написать сервис на Golang работающий по gRPC. Сервис с функциями: Принимает изображения от клиента и сохраняет их. Выводит список загруженных файлов....
Islom's user avatar
  • 23
-2 голоса
1 ответ
79 показов

Посчитать сумму всех элементов двумерного массива используя Parallel Stream и Multithreading Java

Есть метод, который считает сумму всех элементов двумерного массива: int sum2DArray(int[][] array) { int sum = 0; for (int[] ints : array) { for (int number : ints) { sum += number;...
Evgeniy's user avatar
  • 85
-1 голос
1 ответ
82 показа

Коллеги объясните балбесу, почему? код не работает [закрыт]

Так значит проблема вот в чем,решил я решил порефакторить функцию ,а переписал в итоге все покрасивше))) но чего-то не заводится. почему не могу понять))) Помогите))) и да вот репозиторий https://...
YuzameOne's user avatar
0 голосов
2 ответа
255 показов

Как запустить повторяющуюся блокирующую функцию в разных threads с помощью asyncio, python

Есть блокирующая функция, для примера возьмем: def blockme(n): x = random.random() * 2.0 time.sleep(x) return n, x (На самом деле мне нужны реквесты по API, но в контексте данного вопроса ...
Alexey Trukhanov's user avatar
0 голосов
1 ответ
100 показов

Правильная синхронизация с помощью Lock в Java

Доброго времени суток всем. Помогите, пожалуйста, советом. Нужно решить задачу. У меня есть класс с main методом: public class ThreadExample { public static void main(String [] args) { Foo foo = ...
AlvStade's user avatar
0 голосов
1 ответ
28 показов

Корректно ли отработает AtomicInteger?

В моём случае много потоков читают и записывают в одну переменную с проверкой на значение: AtomicInteger value = new AtomicInteger(0); public void threadMethod() { if (value.get() < 30) { ...
Sypchik's user avatar
  • 28
1 голос
0 ответов
35 показов

В книге Thinking in Java 4th Edition дана программа, которая должна работать корректно, но мой код выбросил исключение. Почему?

В книге Thinking in Java 4th Edition дана программа, которая должна работать корректно, но несмотря на это при запуске ExplicitCriticalSection.main() выбросилось исключение. Почему? Вот код ...
Fyodor's user avatar
  • 71
1 голос
2 ответа
118 показов

Конкурентные операции

Всем привет Появилась пара заданий в учебном курсе, в которых требуется, например,сделать запись значений в мапу КОНКУРЕНТНО, возвести значения в квардрат КОНКУРЕНТНО и еще несколько в которых тоже ...
Quester's user avatar
  • 1,045
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 ...
Dmitry Vasiliev's user avatar
0 голосов
1 ответ
54 показа

Выполнение одной подпрограммы множеством потоков

столкнулся с проблемой вернее с тем как заставить множество потоков выполнять одну подпрограмму,насколько я понял в Perl для этого используется функция lock(), но при запуске кода: use warnings; use ...
Женя Медяник's user avatar
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 ...
robopo's user avatar
  • 1
1 голос
1 ответ
294 показа

Как потоки кэшируют переменные или особенности работы volatile

Есть класс сущность с двумя полям (bool/int) и два потока, которые принимаю один и тот же объект этого класса. class MyThread extends Thread { Entity entity; public MyThread(Entity entity) { ...
Kornext's user avatar
  • 15
0 голосов
1 ответ
132 показа

Как обработать задачу и порождённые ею подзадачи с помощью ExecutorService?

Создаётся ExecutorService (допустим, на 10 потоков), который выполняет определённые задачи типа Callable<TaskResult>. Объект класса TaskResult содержит результат выполнения задачи и список ...
Yevhenii Filatov's user avatar
0 голосов
1 ответ
69 показов

Как сделать систему завершения аукционов?

Проблема: Есть аукционы с определенным временем завершения. В это время нужно проставить им статус и перестать принимать ставки. Взять оплату с покупателя и т.д. Как сделать завершение торгов? Мое ...
Pavel  Rodionov's user avatar
2 голоса
2 ответа
134 показа

Насколько большая задержка при многопоточном доступе может быть при обновлении значения без volatile

Предыстория: Есть объект(список объектов на самом деле), в одном из полей которого лежит HashMap. Эта HashMap довольно часто перезаписывается (не значения в ней, а ссылка на объект - т.е. утрируя ...
rjhdby's user avatar
  • 13.9k
2 голоса
1 ответ
80 показов

В чем смысл данных подходов при работе с потоками?

Сейчас я читаю книгу Williams A. C++ Concurrency in Action. Автор предлагает вызывать функцию join() в catch-ветке блока try-catch: void some_func() { // Какая-то функция } void f() { std::...
Eugene's user avatar
  • 33
0 голосов
0 ответов
66 показов

Корутины в использовании базы данных Kotlin

Я новичок в kotlin. Не совсем понимаю, как можно организовать concurrency в работе с базами данных SQLite, в частности корутины. Может ли кто-то, пожалуйста, обьяснить как это сделать?
kk99's user avatar
  • 3
0 голосов
1 ответ
328 показов

Поочередная запись потоками в файл

Всем привет, есть задание: На вход передается целое число, больше 0, кратное 2 (n). Создается два потока, работающих параллельно, каждый поток в цикле, считывает значение из файла out.txt увеличивает ...
DeMmAge's user avatar
  • 677
0 голосов
1 ответ
638 показов

Как сделать методы потокобезопасными? Java

Допустим есть подобный сервис (SomeService), методы getObject() и setPojo() вызываются из RestController (Использую Spring). Вопрос, как сделать этот сервис потокобезопасным в многопоточной среде, ...
SorryForAsking's user avatar
0 голосов
0 ответов
138 показов

Запуск потоков с интервалом (scheduleAtFixedRate(task, 1, 2, TimeUnit.SECONDS)) - SheduledExecutorService

Существует вот такой пример кода public class ExecutorsRunnableRun { public static void main(String[] args) { ScheduledExecutorService scheduledExecutorService = ...
skyho's user avatar
  • 486
0 голосов
1 ответ
45 показов

Конкурентный доступ к кортежу в PostgreSQL

Есть таблица с счетом, на которую наваливается сразу много запросов, которые списывают с него средства: create table account ( id BIGSERIAL PRIMARY KEY, volume BIGINT NOT NULL DEFAULT 0 ); ...
Pavel's user avatar
  • 5,297
0 голосов
0 ответов
42 показа

Вопрос об асинхронном методе [дубликат]

Есть вопрос по поводу асинхронной реализации метода, в каких случаях она выгодна? сейчас метод выполняется быстрее чем его реализация, а если синхронизировать с помощью семафор не вижу сильных отличий ...
Artemii Kurilko's user avatar
0 голосов
0 ответов
60 показов

Почему код из Java Concurrency in Practice считается безопасным

читаю книгу Java Concurrency in Practice и один пример "безопасного" кода из 3 главы насторожил меня. В книге сказано, что использование volatile-переменных в связке с неизменяемыми ...
m_luk's user avatar
  • 1
0 голосов
1 ответ
256 показов

Использование GCD в Swift

Всем привет! Никак не могу понять принцип работы многопоточности с GCD. Я понимаю, что есть некая абстракция, названная "Потоки", в которой выполняются какие-то таски. Понимаю, что мы не управляем ...
TheGreatVY's user avatar
0 голосов
0 ответов
777 показов

Обработка чисел из двух каналов и запись в третий на Go

Написал решение задачи на Go. Решение компилируется но на тестах выдаёт, что ожидает одно число из канала, а получает другое. Помогите разобраться, где ошибка. Задание: Необходимо написать функцию ...
Jegors Čemisovs's user avatar
0 голосов
1 ответ
115 показов

Как наиболее эффективно синхронизировать коллекцию?

Пишу RESTful сервис на Spring. Имеется класс CarProviderService, его зона ответственности - обновление ArrayList'а cars. Раз в минуту с предоставлением актуального состояние этого листа другим ...
Дмитрий Мишенёв's user avatar
0 голосов
0 ответов
78 показов

Как корректно обновить значение в ConcurrentHashMap в многопоточной среде

У меня есть довольно простой класс, который собирает статистику по статусам. public class Status { private ConcurrentMap<String, AtomicInteger> statusesMap = new ConcurrentHashMap<>()...
Violetta's user avatar
  • 145
0 голосов
0 ответов
61 показ

ReentrantLock не всегда справляется с блокировкой общего ресурса

Имеем задачу следующего содержания: есть порт, в порту - несколько доков, к которым причаливают корабли (у одного дока может стоять на погрузке/выгрузке только 1 корабль в какой-то момент времени). ...
overdd's user avatar
  • 65
0 голосов
1 ответ
202 показа

Почему нельзя "присоединить" поток std::thread дважды?

Скажем, мы хотим дожидаться одного потока в нескольких других, но по идее не можем этого сделать благодаря такому ограничению (из книги C++ Concurrency in Action): При вызове join() очищается вся ...
megorit's user avatar
  • 1,947
0 голосов
1 ответ
75 показов

Запрос к БД внутри ConcurrentHashMap.compute()

Запрос к БД внутри ConcurrentHashMap.compute() при условии низкой нагрузки на map, насколько это корректно ? В java doc написано про метод compute Some attempted update operations on this map by ...
user2854511's user avatar
0 голосов
0 ответов
156 показов

Проблема с CompletableFuture

Всем привет, у меня приложение отправляет письмо на почту, иногда почтовый сервер зависает и ничего не отдает, и соответственно приложение на отправку тоже, лечится после рестарта приложения. Чтобы ...
Владислав's user avatar
0 голосов
1 ответ
38 показов

Концепция Fail-Fast итераторов

Доброго времени суток. Если я правильно понимаю, Fail-Fast итераторы сразу прекращают работу (обычно посредством генерации исключений), если обнаружат, что набор данных по которому они итерируются ...
Bakuard's user avatar
  • 972
2 голоса
1 ответ
358 показов

Многопоточный ping-pong. Использовать memory_order_acquire / memory_order_release или memory_order_relaxed?

Имеется код пинг-понга (использую MSVC 2017). Вопрос: является ли он корректным? или нужно использовать memory_order_acquire и memory_order_release? При запуске он работает нормально. #include <...
Temp12's user avatar
  • 23
0 голосов
1 ответ
675 показов

Golang. Как распараллелить обработку слайса, чтобы получить выигрышь в скорости?

Есть слайс, содержащий большое количество элементов, допустим 100000. Мне необходимо написать функцию, которая умножит каждый элемент данного слайcа на 2. Я хочу, чтобы эта функция работала ...
wintermonth's user avatar
0 голосов
1 ответ
276 показов

Неблокирующий параллельный алгоритм поиска максимума и его индекса

Существует ли неблокирующий параллельный алгоритм поиска максимального элемента массива а также его индекса? Есть такая реализация, AtomicInteger atomicMin = new AtomicInteger(99999); AtomicInteger ...
Asem's user avatar
  • 865
1 голос
0 ответов
376 показов

Если бы ASP.NET Core был одно-поточен

Многопоточность Согласно моему познанию ASP.NET Core и если сильно не углубляться в детали, то на сегодняшний день обработка HTTP-запросов на одноядерном процессоре происходит следующим образом: ...
Adam Shakhabov's user avatar
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 ...
insFriZzz's user avatar
  • 168
0 голосов
1 ответ
106 показов

Executors. Как прекращать работу потоков?

Я делаю некий таймер. При его запуске выполняется какая-то последовательность действий, после чего поток должен закрыться и не грузить дальнейшую работу программы. Как мне его адекватно остановиться, ...
ForsaiR's user avatar
  • 35
1 голос
1 ответ
27 показов

Как вызвать InteraptedException для потоков ожидающий блокировку методом lockInterruptibly из java.util.concurrent.locks.Lock

Есть ли способ получить все потоки ожидающие блокировки и вызвать на них interrupt из критической области, потоком владеющим блокировкой ?
Сергей Куренчук's user avatar
0 голосов
1 ответ
137 показов

Go concurrency и использование общей переменной

Изучая Go, придумал себе задачу. Есть некий URL вида https://host/id. На некоторых айдишниках есть контент, на некоторых возвращает сообщение о том, что нет ничего по такому айдишнику. Задача: чтобы ...
Alex Sazonov's user avatar
  • 2,836
0 голосов
1 ответ
257 показов

Future и получение данных по мере их выполнения

Помогите разобраться пожалуйста. Шлю запрос в базюки и получаю время выполнения запроса. Ниже представлен метод в контроллере, в котором в теле запроса я передаю какой-то запрос. Создаю пул из 3 ...
ks2017's user avatar
  • 153
2 голоса
1 ответ
904 показа

Потокобезопасный ArrayList

Пишу свою реализацию потокобезопасного эррэй листа на CAS-блокировках (не спрашивайте зачем). Столкнулся с некоторым непонятным мне поведением в процессе записи элементов в лист. Код реализации ...
stroiker's user avatar
1 голос
0 ответов
62 показа

Кэш для нагруженного веб приложения

Приложение отдает одинаковые данные клиентам. Например список стран. Я хочу сделать так, чтобы не нужно было постоянно дергать базу, а при первом запуске приложения считывать в кэш этот справочник и ...
Pavel  Rodionov's user avatar
0 голосов
1 ответ
384 показа

Конкурентная загрузка файлов через http.Client, golang

Прошу помочь разобраться с такой проблемой. Пробую получать файлы Get-запросом в нескольких горутинах: type RemoteImages []RemoteImage type RemoteImage struct { Lang string `json:"lang"` ...
tews's user avatar
  • 83
1 голос
2 ответа
32 показа

Видимость в фоновом потоке значения, измененного в главном потоке

В этом коде есть проблема: фоновый поток не остановится никогда. Почему это происходит? В книге объяснение такое: без синхронизации нет гарантированного времени, когда фоновый поток увидит измененное ...
typemoon's user avatar
  • 2,475
0 голосов
0 ответов
39 показов

использование ConcurentBag при работе с БД

Как можно использовать ConcurrentBag при работе с БД? и в каких случаях это нужно. Большинство примеров рассмотрены с добавлением string/int значений. К коллекции применяются Linq-запросы, коллекция ...
Юрик Тао's user avatar
0 голосов
1 ответ
131 показ

Многопоточный доступ к коллекции Java

Начал изучать многопоточность в Java и возник следующий вопрос: У меня есть некая коллекция, допустим map, которая содержит объекты Account c полем flot money = 100; Я хочу запустить 4 потока, которые ...
Iryaz_Lock's user avatar
-2 голоса
2 ответа
259 показов

Невозможность асинхронного вызова recvfrom()

Вызов recvfrom() из вызванной асинхронно функции блокирует не только нить, в которой функция, но и вызывавший поток (возврат в него не происходит). Почему и как это обойти? ps Это, если верно считаю,...
Sawa Akisawa's user avatar
-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+...
Sawa Akisawa's user avatar