multithreading- все статьи тега ➜ страница 2
Являются ли контроллеры rails многопоточными? Нить.эксклюзив в контроллерах
Являются ли контроллеры Rails многопоточными? Если это так, Могу ли я защитить определенный фрагмент кода (который срабатывает только один раз в десять минут) от запуска из нескольких потоков, просто выполнив require 'thread' Thread.exclusive do # stuff here end On нужно ли как-то синхронизировать на мониторе? ...
Как подключить несколько клиентов к одному серверу в c++ на Windows-Visual Studio? [дубликат]
На этот вопрос уже есть ответ здесь: один сервер TCP / IP, который обрабатывает несколько клиентов (в C++)? 2 ответа Я написал серверную программу на C++, а также клиентскую программу на C++. Оба работают нормально, но если один клиент взаимодействует с сервером, то другой клиент не может подключиться к тому же серверу. Если предположим когда я закрываю клиент 1, то и мой 2-й клиент не может подключитьс ...
Блоки потока данных TPL, работающие в потоке пользовательского интерфейса
Я строю конвейер потока данных для выполнения различных операций обработки(в основном ввода-вывода, но некоторые операции процессора), которые находятся в естественном потоке. Поток в настоящее время находится в этой основной схеме: загрузка данных из файла разбор записи с помощью блока преобразования сериализация и загрузка объекта на сервер через REST Этот конвейер обработки может быть запущен автоматически или через графический интерфейс пользователя. Для того, когда он запускается и ...
Как приоритеты потоков Java переводятся в приоритет потоков ОС?
Как приоритеты потоков java API (1-10)переводятся в приоритеты уровня ОС, так как большинство ОС не имеют уровней приоритета потоков (в терминах числа), которые соответствуют этому. Таким образом , имея в виду, может ли быть сценарий, когда два или более потоков с различными приоритетами в конечном итоге получить тот же приоритет на уровне ОС. Пожалуйста, уточните, есть ли какая-то коррекция в моем понимании. ...
Завершение всех дочерних потоков при закрытии рабочей области / окна
У меня есть несколько экземпляров дочерних потоков, которые запускаются и должны продолжать выполняться до завершения работы приложений. У меня есть классы, которые расширяют задачу, и я создаю потоки как new Thread(object of the class).start(); Все потоки должны быть завершены при закрытии первичной стадии. primaryStage.onCloseOperation(){...} ...
кэш объектов Python threadsafe
Я реализовал веб-сервер python. Каждый http-запрос порождает новый поток. У меня есть требование кэширования объектов в памяти, и поскольку это веб-сервер, я хочу, чтобы Кэш был потокобезопасным. Существует ли стандартная реализация кэша потокобезопасных объектов в python? Я нашел следующее Http://freshmeat.net/projects/lrucache/ Это не выглядит потокобезопасным. Может ли кто-нибудь указать мне на хорошую реализацию потокобезопасного кэша в в Python? Спасибо! ...
Правильное использование ConcurrentQueue в HttpModule?
Я пытаюсь добавить ускорение к HttpModule, который обрабатывает изображения с помощью асинхронного программирования. Хотя, безусловно, кажется, что я получаю улучшение производительности, я хотел бы проверить, правильно ли я использую предоставляемые инструменты. Меня особенно беспокоит, что я неправильно обрабатываю очередь. Подход, который я использую. Init The ConcurrentQueue добавьте метод ProcessImage в очередь on то BeginEventHandler в AddOnBeginRequestAsync обработать очередь на E ...
TCP-соединение-сервер отправляет сообщение только после закрытия сокета
Я пытаюсь заставить клиента отправить запрос на сервер и получить ответ, сохраняя соединение. Если я закрою сокет: //server side outToClient.writeBytes("Message to send"); connectionSocket.close(); //client side serverResponse = inFromServer.readLine(); System.out.println("FROM SERVER: " + serverResponse); Вывод на стороне клиента От сервера: сообщение для отправки И после этого связь, очевидно, теряется. Если я не закрою сокет: //server side outToClient.writeBytes("Message to ...
Пробуждение потоков с помощью QWaitCondition
Мое приложение Qt имеет рабочий поток, который обрабатывает новые данные, когда они доступны. До сих пор рабочий поток использовал QWaitCondition для пробуждения при появлении новых данных. Однако условие QWaitCondition запускается только тогда, когда поток активно ожидает через wait(). Однако может случиться так, что новые данные будут доступны, пока поток все еще работает, или непосредственно перед тем, как он перейдет к следующей команде wait (). Я ищу что-то вроде CEvent в MFC, который "п ...
Лучший способ сделать многопоточный цикл foreach [закрыт]
У меня есть метод отправки электронной почты с foreach, например: static void Main(string[] args) { foreach(var user in GetAllUsers()) { SendMail(user.Email); } } Мне нужно усовершенствовать этот метод. Используя многопоточность, потому что я не хочу ждать, когда метод SendMail будет выполняться каждый раз для каждого пользователя. Есть какие-нибудь способы сделать это? Спасибо ...
Как открыть ClientDataSet (master / detail) в отдельном потоке (отличном от основного потока)
Использование: Delphi XE2, DBExpress, Firebird Я не могу безопасно получить доступ к любому элементу управления VCL вне основного потока, который включает формы, панели, правки и т. д., а также потомки Timage и Timage. Мне нужно открыть ClientDataSet (Master / Detail) в отдельном потоке(отличном от основного потока). Мне нужно создать анимированный заставочный экран при доступе к базе данных Может ли кто-нибудь показать мне простой пример того, как это сделать? ...
Как обновить SWT GUI из другого потока в Java
Я пишу настольное приложение, используя SWT. Каков самый простой способ обновить элементы управления GUI из другого потока? ...
Как найти имя родительского потока?
Я знаю, что у нас могут быть "родители" и "дети", когда мы говорим о процессах. Но можно ли получить имя родителя Thread? Я провел свое исследование, но нашел ответ только для .Net Edit: я пытался установить имена: public class Main { public static void main(String[] args) { Thread r = new ThreadA(); r.start(); } } public class ThreadA extends Thread { public void run() { Thread.currentThread().setName("Thread A"); System.out.println("Here ...
Как распараллелить выполнение обработчика событий в C#
У меня есть устройство Kinect, и я разрабатываю программу с его помощью, используя C#. Для управления устройством я использовал событие AllFramesReady для обработки информации о глубине и цвете. Я создал обработчик событий для обработки данных, который называется EventHandler1. Я делаю много обработки внутри этого обработчика событий. Я хотел бы сделать еще несколько вычислений внутри второго обработчика событий с именем EventHandler2. Можно ли запустить эти 2 обработчика событий какие в осн ...
Спинвейт против ожидания сна. Какой из них использовать?
Является ли это эффективным для SpinWait.SpinUntil(() => myPredicate(), 10000) Для таймаута 10000ms Или Эффективнее ли использовать Thread.Sleep опрос для того же условия Например, что-то вроде следующей функции SleepWait: public bool SleepWait(int timeOut) { Stopwatch stopwatch = new Stopwatch(); stopwatch.Start(); while (!myPredicate() && stopwatch.ElapsedMilliseconds < timeOut) { Thread.Sleep(50) } return myPredicate() } Я обеспокое ...
Использование C# ConcurrentBag с несколькими производителями и одним потребителем
У меня есть ситуация, когда несколько потоков создают один объект ICollection. ConcurrentBag кажется лучшим (?) решение, так как-1) каждый поток будет иметь свою собственную локальную очередь, и 2) потокам не нужно общаться - они независимы. Пока все хорошо, но правда в том, что мне нужно вернуть Исет из этого метода (после того, как все производители прекратили). Даже если текущий экземпляр ConcurrentBag отличается от (это гарантируется логикой приложения) , Мне все еще нужно преобразовать его ...
Потокобезопасная глобальная переменная в Java
Я пытаюсь понять механизм потокобезопасности в java, и мне нужна помощь. У меня есть класс: public class ThreadSafe { private Executor executor = new ScheduledThreadPoolExecutor(5); private long value = 0; public void method() { synchronized (this) { System.out.println(Thread.currentThread()); this.value++; } } private synchronized long getValue() { return this.value; } public static void main(String... args) { ...
Блокировка геттера и сеттера булевых свойств
Есть ли какая-либо причина, по которой вы создаете блокировки вокруг геттера и сеттера логического свойства, подобного этому? private _lockObject = new object(); private bool _myFlag; public bool MyFlag { get { lock (_lockObject) { return _myFlag; } } set { lock (_lockObject) { _myFlag = value; } } } ...
System.AccessViolationException:.NET ошибка выполнения рабочего потока c#
У меня есть picturebox в моей форме windows, который отображает поток с моей камеры он использует рабочий поток, как вы можете видеть: VideoFileReader reader = new VideoFileReader(); Thread Proceso1; Proceso1 = new Thread(new ThreadStart(updateui)); public void updateui() { try { reader.Open(RTSPAddress); while (true) { var previousFrame = pictureRTSP.BackgroundImage; ...
Потокобезопасные мультитоны в Java
Дано следующее многотонное: public class Multiton { private static final Multiton[] instances = new Multiton[...]; private Multiton(...) { //... } public static Multiton getInstance(int which) { if(instances[which] == null) { instances[which] = new Multiton(...); } return instances[which]; } } Как мы можем сохранить его потокобезопасным и ленивым без дорогостоящей синхронизации метода getInstance() и споро ...