15 голосов
Принятый

Почему optimistic locking так назвали?

В случае использования оптимистической блокировки (optimistic lock) вы сначала пытаетесь выполнить действия, а уже потом смотрите не приводит ли результат к несогласованности данных (конфликту ...
Dmitriy Simushev's user avatar
6 голосов
Принятый

видимость значения при синхронизированном изменении

Модификаторы volatile и synchronized решают ведь не только проблему с кэшированием. Есть ещё масса нюансов, которые требуется учитывать в многопоточном программировании. Например, reordering. Есть ряд ...
Sergey Gornostaev's user avatar
5 голосов

Ключевое слово volatile в Java

volatile - говорит потоку что переменная может меняться, и информирует поток о необходимости обращаться к последней версии, а не к хешированной копии и своевременно распространять изменения. A "...
Aliaksandr Shpak's user avatar
5 голосов

Ключевое слово volatile в Java

volatile - буквально означает летучий, непостоянный, изменчивый в контексте программирования это означает, что значение переменной может неожиданно изменяться, поэтому не стоит полагаться на значения ...
Barmaley's user avatar
  • 81.3k
5 голосов

Ключевое слово volatile в Java

для объектным ссылок volatile можно не писать. я прав? Например, когда мы в многопоточном приложении используем паттерн Синглтон в котором применяем синхронизацию и хотим чтобы синхронизация ...
Eugene Goliuk's user avatar
5 голосов

Блокирующий элемент очереди

Я обычно использую кэш, в котором держу объекты для синхронизации. Ehcache idLockingCache = ..... ; private Lock idLockingCacheLock = new ReentrantLock(); public Object getLock(String key) { ...
Russtam's user avatar
  • 2,663
5 голосов
Принятый

Ожидание нажатия кнопки

Нельзя делать Thread.sleep(...) в UI-потоке, ибо если Вы заблокируете UI-поток, то, спустя несколько секунд, получите ANR (Application not responding) с предложением о принудительной остановке ...
post_zeew's user avatar
  • 22k
5 голосов
Принятый

Где использовать volatile

Модификатор volatile гарантирует видимость операций с полем и сохранение их последовательности. Волатильную переменную можно, например, использовать как флаг завершения работы потока: public class ...
Sergey Gornostaev's user avatar
5 голосов
Принятый

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

Делаете N потоков, каждый из которых ищет индекс максимального элемента на своем участке массива, затем выбираете максимальный из найденных N максимумов - это и будет максимальный элемент во всем ...
user7860670's user avatar
  • 29.9k
4 голоса

Возможно ли комбинировать несколько способов синхронизации?

synchronized, wait, notify и notifyAll работают в связке - это примитивы. ReentrantLock - это высокоуровневая конструкция и реализована она через примитивы. Вы можете сами создать высокоуровневые ...
Mikhail Vaysman's user avatar
4 голоса
Принятый

Vector, Hashtable. В чем минус синхронизированности?

Потокобезопасность это же хорошо. Потокобезопасность не бесплатна, точнее очень не бесплатна, именно поэтому есть потокобезопасные и не потокобезопасные коллекции. Если однопоточная среда, это как-...
Slava Vedenin's user avatar
4 голоса
Принятый

Конкурентное программирование. async с отложенным await. C#

Сразу приведу минимальный пример консольного приложения, который можно скопировать и запустить. Три варианта метода Delay: ваш, полностью синхронный и псевдоасинхронный. Сделан замер времени ...
Alexander Petrov's user avatar
4 голоса
Принятый

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

В вашем примере вызывается функция do_something_in_current_thread(); и если всё выполнено успешно, то ждать окончания потока. А если произошло исключение в текущем потоке (в функции ...
AlexGlebe's user avatar
  • 17.2k
3 голоса
Принятый

ConcurrentDictionary. Потокобезопасность методов расширения

Запросы LINQ к ConcurrentDictionary являются потокобезопасными, но не являются атомарными. Потокобезопасность означает что вы не получите повреждения структуры, случайных вылетов или некорректных ...
Pavel Mayorov's user avatar
3 голоса
Принятый

Что отправлять на выполнение в тредпулл, runnable или thread

Используйте Future, который возвращается методом executorService.submit(...), а затем вызывайте future.cancel с параметром mayInterruptIfRunning равным true ExecutorService executorService = ...
iksuy's user avatar
  • 10.5k
3 голоса

Как понять что в данный код безопасен для многопоточной среды?

Данный код безопасен для многопоточной среды по той простой причине, что класс OneValueCache является immutable, то есть его внутреннее состояние после его создания изменить невозможно. Если залезть в ...
Barmaley's user avatar
  • 81.3k
3 голоса
Принятый

Распараллеливание стримов

А почему нет? IntStream.range(0, size()) .parallel() .forEach(i -> { if(get(i) & anotherVector.get(i)){ intersectionVector.set(i); }...
iksuy's user avatar
  • 10.5k
3 голоса
Принятый

Вызов шаблонной функции через Qtconcurrent::run

exceptionWrapper сам по себе не является функцией, но неким шаблоном функции, поэтому мы не можем никуда его передать — мы можем передавать лишь что-то конкретное, а не абстракцию, коей является ...
ixSci's user avatar
  • 23.8k
3 голоса
Принятый

Вопрос про доступность полей и методов объекта synchronized блока

Тут три варианта: либо вопрос поставлен некорректно, либо ответы сформулированы не совсем ясно (особенно третий, который можно трактовать в сторону правильного), либо в тесте ошибка и правильного ...
post_zeew's user avatar
  • 22k
3 голоса

Условие закрытие пула потоков

Используйте java.util.concurrent.ThreadPoolExecutor, он гибче в использовании. Пример для вашей задачи: ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(4, 4, 1, TimeUnit....
Artem's user avatar
  • 15k
3 голоса

Условие закрытие пула потоков

Обычно пулы потоков завершаются только при завершении самого приложения: автор приложения знает, что у него есть некоторая фоновая обработка задач, пул слушателей базы данных, поэтому можно их один ...
etki's user avatar
  • 36.1k
3 голоса

Правильная организация потоков

Еще интересный вариант - использовать пул потоков from multiprocessing.dummy import Pool as ThreadPool try: from urllib.request import urlopen except ImportError: from urllib2 import urlopen ...
rusnasonov's user avatar
  • 1,211
3 голоса

Правильная организация потоков

Простой компактный пример использования многопоточности как раз для работы с HTTP-запросами (взят отсюда): import Queue import threading import urllib2 def get_url(q, url): q.put(urllib2....
cridnirk's user avatar
  • 691
3 голоса
Принятый

submit и invoke в ForkJoinPool

invoke - задача будет выполнена и будет возвращен результат задачи. execute и submit возвращают задачу в очередь и может быть продолжена и в другом потоке. То есть не ждет завершения задачи Если вы ...
Senior Pomidor's user avatar
3 голоса
Принятый

Синхронизация фукнций с condition_variable C++

Если у вас функция f2 вызывается намного реже функции f1, то думаю, вы можете реализовать spin-блокировку с помощью std::atomic_flag #include <atomic> #include <chrono> #include <...
Alexcei Shmakov's user avatar
3 голоса
Принятый

Looper для обновления виджетов

Можно воспользоваться TimerTask, если код должен выполняться, когда приложение запущено Handler handler = new Handler(); Timer timer = new Timer(); TimerTask timerTask = new TimerTask() { ...
Komdosh's user avatar
  • 12.1k
3 голоса
Принятый

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

Самый простой и быстрый способ это изменить ссылку: ... List<Car> newCars = new ArrayList<>(); /* Заполняем лист newCars новыми данными, после чего обновляем cars*/ cars = newCars; ...
Roman-Stop RU aggression in UA's user avatar
3 голоса
Принятый

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

Сразу целая куча проблем: семафор захватываете перед циклом, а отпускаете внутри. После первой итерации семафор отпущен, а поток продолжает себе работать с файлом. Нужно захватывать один раз в начале ...
Roman-Stop RU aggression in UA's user avatar
3 голоса

Не могу понять, о чём говорится в книге по Go

Разница между task stealing и continuation stealing в том, что является единицей управления планировщика. В традиционной модели многопоточности вызов параллельной функции выполняется в отдельном ...
Pak Uula's user avatar
  • 15.4k
2 голоса
Принятый

Как работает java.util.concurrent.Phaser?

Phaser -- это разновидность барьера, аналогичен CyclicBarrier и CountDownLatch, но отличается более гибкой настройкой. Барьер в общем виде представляет собой следующее: задается количество потоков, ...
andreycha's user avatar
  • 25.2k

Допускаются только превышающие минимальную длину ответы с наивысшим рейтингом, не являющиеся общими