При программировании сокетов вы создаете прослушивающий сокет, а затем для каждого подключающегося клиента вы получаете обычный потоковый сокет, который можно использовать для обработки запроса клиента. ОС незаметно управляет очередью входящих подключений. Два процесса не могут одновременно...
Есть ли способ отформатировать десятичную дробь следующим образом: 100 -> "100" 100.1 -> "100.10" Если это круглое число, опустите десятичную часть. В противном случае форматируйте с двумя десятичными знаками....
Изучая использование подсказок по таблицам , я столкнулся с двумя вопросами: Какие подсказки блокировки мне следует использовать (T-SQL)? Как влияет HOLDLOCK на UPDLOCK? Ответы на оба вопроса говорят о том, что при использовании (UPDLOCK, HOLDLOCK)другие процессы не смогут читать данные в этой...
Есть ли хорошее и краткое объяснение того, как работают Актеры по сравнению с потоками? Разве поток нельзя рассматривать как актера и отправлять сообщения другим потокам? Я вижу некоторую разницу, но для меня это не так ясно. Могу ли я использовать актеров на любом языке, используя потоки...
Мне очень нравятся эти инструменты, когда дело касается уровня параллелизма, с которым они могут справиться. Erlang / OTP выглядит гораздо более стабильным решением, но требует гораздо большего изучения и глубокого погружения в парадигму функционального языка. И похоже, что Erlang / OTP делает его...
Закрыто . Этот вопрос должен быть более конкретным . В настоящее время он не принимает ответы. Хотите улучшить этот вопрос? Обновите вопрос, чтобы он фокусировался только на одной проблеме, отредактировав этот пост . Закрыт 5 лет назад . Уточните этот вопрос Недавно мне задали этот вопрос в...
В версии, предшествующей выпуску go 1.5 веб-сайта Tour of Go , есть фрагмент кода, который выглядит следующим образом. package main import ( "fmt" "runtime" ) func say(s string) { for i := 0; i < 5; i++ { runtime.Gosched() fmt.Println(s) } } func main() { go say("world") say("hello") }...
Предположим , у меня есть несколько фьючерсных и нужно ждать , пока либо ни один из них не откажет или все из них успеха. Например: Пусть есть 3 фьючерсов: f1, f2, f3. В случае f1успеха и f2неудачи я не жду f3(и возвращаю ошибку клиенту). Если f2не удается пока f1и f3все еще работает , я не ждать...
Я пытаюсь закодировать решение, в котором один поток создает задачи с интенсивным вводом-выводом, которые могут выполняться параллельно. Каждая задача имеет важные данные в памяти. Поэтому я хочу иметь возможность ограничивать количество задач, ожидающих выполнения в данный момент. Если я создам...
Является ли доступ к полю bool атомарным в C #? В частности, мне нужно поставить блокировку: class Foo { private bool _bar; //... in some function on any thread (or many threads) _bar = true; //... same for a read if (_bar) { ... } }...
Я только что видел эту структуру данных в API Java 6, и мне любопытно, когда это будет полезным ресурсом. Я готовлюсь к экзамену scjp, и я не вижу, чтобы он освещался в книге Кэти Сьерра, хотя я видел пробные экзаменационные вопросы, в которых это упоминается....
Правильно ли я считаю, что это правильное использование параллельного словаря private ConcurrentDictionary<int,long> myDic = new ConcurrentDictionary<int,long>(); //Main thread at program startup for(int i = 0; i < 4; i++) { myDic.Add(i, 0); } //Seperate threads use this to update a...
Приведенный ниже код дает ошибку компиляции, говорящую о неожиданном запуске: x := go doSomething(arg) func doSomething(arg int) int{ ... return my_int_value } Я знаю, что могу получить возвращаемое значение, если вызову функцию как обычно, без использования горутины. Или я могу использовать...
У меня есть класс, который берет объекты из a BlockingQueueи обрабатывает их, вызывая take()в непрерывном цикле. В какой-то момент я знаю, что больше никаких объектов в очередь не будет. Как мне прервать take()метод, чтобы он перестал блокироваться? Вот класс, обрабатывающий объекты: public class...
Как можно использовать многопроцессорность для решения неприятно параллельных задач ? Ужасно параллельные проблемы обычно состоят из трех основных частей: Чтение входных данных (из файла, базы данных, TCP-соединения и т. Д.). Выполните вычисления с входными данными, при этом каждый расчет не...
Как очистить ConcurrentBag? у него нет такого метода, как Clearили RemoveAll...
Будет ли он возвращать false только в том случае, если словарь не содержит значения для данного ключа, или он также вернет false из-за условий гонки потоков, например, другой поток добавляет / обновляет что-то? Вопрос в коде: ConcurrentDictionary<int, string> cd = new...
Модель программирования node.js, управляемая событиями, несколько усложняет координацию выполнения программы. Простое последовательное выполнение превращается во вложенные обратные вызовы, что достаточно легко (хотя и немного запутано для записи). Но как насчет параллельного выполнения? Скажем, у...
Пытаясь понять, как SubmissionPublisher( исходный код в Java SE 10, OpenJDK | docs ), новый класс, добавленный в Java SE в версии 9, был реализован, я наткнулся на несколько вызовов API, о которых VarHandleраньше не знал: fullFence, acquireFence, releaseFence, loadLoadFenceИ storeStoreFence....
Мне нужен какой-то сервис, который будет запускать несколько задач одновременно и с интервалом в 1 секунду в течение 1 минуты. Если одна из задач не выполняется, я хочу остановить службу и все задачи, которые выполнялись вместе с каким-то индикатором, что что-то пошло не так, иначе, если через одну...