Результаты поиска по запросу "concurrency"
Модульное тестирование параллельного кода
Мой проект выходного дня состоит из написания библиотеки кроссплатформенных примитивов параллелизма (критических разделов, мьютексов чтения / записи, взаимосвязанных целых чисел, событий и т. Д.), И мне было интересно, как выполнить модульное ...
@ Энтони - микро-бенчмаркинг - это не зло. Просто трудно получить значимые результаты, применимые к вашему реальному сценарию использования.
я есть требование для ленивой загрузки ресурсов в параллельной среде. Код для загрузки ресурсов должен быть выполнен только один раз. ОбеДвойная проверка ...
Следующая измененная версия работает для меня:
ужно позвонить в службу, которая может или не вернуть своевременные результаты. Я хотел бы иметь возможность написать val result = runWithTimeout(5000, valReturnedOnTimeout) { service.fetch }Есть ли стандартная функция, которая будет делать эту ...
Мне понравилось это звучание, но FutureActor является частным и достаточно сложным, чтобы воспроизводить его было бы волосатым.
отал над моим ответомСуществует ли стандартная функция Scala для запуска блока с таймаутом? [https://stackoverflow.com/q/6227759/97777]и столкнулись с проблемой, если в будущем возникнет исключение. def runWithTimeout[T](timeoutMs: Long)(f: => ...
В этом случае объект не должен быть «потокобезопасным»
аю Java Concurrency на практике и путаюсь с концепцией ограничения потока. Книга говорит, что Когда объект ограничен потоком, такое использование автоматически потокобезопасно, даже если сам ограниченный объект не является Так, когда объект ...
Если вы работаете в цикле, над которым у вас есть некоторый контроль, вы можете использовать tic и toc, чтобы узнать, как долго вы работаете, и остановиться, если это было слишком долго:
я есть код MATLAB, который для некоторых случаев ввода занимает бесконечное время для выполнения. Я хотел бы исключить из выполнения моего кода те входные значения, которые заставляют мою функцию MATLAB занимать более X минут, поскольку MATLAB ...
Совместное использование состояния между разветвленными рабочими процессами в высокопроизводительной среде
Это продолжение моегопредыдущий вопрос [https://stackoverflow.com/questions/20955683/python-multiprocessing-sharing-a-complex-object/] , Как предположил Тим Питерс, используяManager не обязательно может быть лучшим подходом. К сожалению, у меня ...
https://github.com/celery/celery/tree/master/examples/gevent
у приложение на Python, которое требует одновременности и асинхронности. У меня было несколько рекомендаций для Twisted и Celery, но у меня возникли проблемы с определением, какой из них лучше подходит для этого приложения (у меня нет ...
Нет, это плохой способ завершить поток, Thread.Abort () не является безопасным.
ужно разработать многопоточную рабочую роль Azure в C # - создавать несколько потоков, направлять запросы к ним, каждый запрос может потребовать очень много времени для обработки (не мой код - я вызову объект COM для выполнения ...
это всего лишь предположение, так как я не знаком с OF в Linux, но я думаю, что для доступа к функциональности RT требуется доступ к низкоуровневому устройству ALSA. Таким образом, он не может использовать устройство совместно с PulseAudio (или чем-либо еще, что они используют в наши дни), что позволяет совместно использовать аудиоустройства между приложениями. Вы можете попробовать посмотреть на JACK для мультиплексирования между PulseAudio и вашей программой ALSA.
я пытаюсь выполнить audioOutputExample, поставляемый сopenFrameworks [http://www.openframeworks.cc/], Я получил RtApiAlsa :: getDeviceIno: snd_pcm_open ошибка для устройства (hw: 0,0), устройство или ресурс занят. RtApiAlsa :: probeDeviceOpen: ...