Perguntas com a marcação «multithreading»

Estou enfrentando um problema em que, se eu tentar redimensionar o ThreadPoolExecutortamanho de um pool principal para um número diferente após a criação do pool, então, de forma intermitente, algumas tarefas serão rejeitadas, RejectedExecutionExceptionmesmo que eu nunca envie mais do que um...

Depois de olhar para um monte de outras questões e suas respostas , fico com a impressão de que não há um acordo generalizado sobre o que a palavra-chave "volátil" em C significa exatamente. Mesmo o próprio padrão não parece suficientemente claro para que todos concordem com o que isso significa...

Preciso de algum tipo de serviço que execute algumas tarefas simultaneamente e em um intervalo de 1 segundo por 1 minuto. Se uma das tarefas falhar, quero interromper o serviço e todas as tarefas executadas com algum tipo de indicador de que algo deu errado; caso contrário, após um minuto tudo...

Eu uso std::for_eachcom std::execution::parpara executar computação complexa em entradas enormes representadas como vetor de estruturas. O cálculo não precisa de atrasos relacionados ao hardware (E / S de rede ou disco, por exemplo), é "apenas CPU". Para mim, parece lógico que não faz sentido criar...

Eu tenho uma lista que eu quero tópicos diferentes para pegar elementos. Para evitar o bloqueio do mutex que guarda a lista quando está vazio, eu verifico empty()antes de bloquear. Tudo bem se a chamada para list::empty()não estiver correta 100% do tempo. Eu só quero evitar bater ou interromper...

Estou usando o flutter desktop para linux. Estou chamando um método chamado MarkTextureFrameAvailableque deve marcar uma textura a ser renderizada novamente pelo mecanismo. Como estou programando um player de vídeo, preciso ligar MarkTextureFrameAvailabledo thread do player. O problema é que o...

Alguém pode me dizer se std :: atomic :: is_lock_free () não é estático, assim como constexpr? Tê-lo não estático e / ou não constexpr não faz sentido para

A frase "fortemente acontece antes" é usada várias vezes no rascunho do padrão C ++. Por exemplo: Rescisão [basic.start.term] / 5 Se a conclusão da inicialização de um objeto com duração de armazenamento estático ocorrer fortemente antes de uma chamada para std :: atexit (consulte...

Estou tentando processar o código abaixo usando multithreading no nível do pedido. List<String> orders = Arrays.asList("order1", "order2", "order3", "order4", "order1"); Execução sequencial atual: orders.stream().forEach(order -> { rules.forEach(rule -> {

Eu inicio um processo filho spawn desta maneira: let process = spawn(apiPath, { detached: true }) process.unref() process.stdout.on('data', data => { /* do something */ }) Quando inicio o processo, preciso mantê-lo anexado, porque quero ler sua saída. Mas, pouco antes de fechar meu processo...

O JavaFX docs estado que um WebViewestá pronto quando Worker.State.SUCCEEDEDé atingido no entanto, a menos que você esperar um pouco (ou seja Animation, Transition, PauseTransition, etc.), uma página em branco é processado. Isso sugere que há um evento que ocorre dentro do WebView, preparando-o...

Aqui está o que eu quero dizer: public Task<SomeObject> GetSomeObjectByTokenAsync(int id) { string token = repository.GetTokenById(id); if (string.IsNullOrEmpty(token)) { return Task.FromResult(new SomeObject() { IsAuthorized = false }); } else { return

Abaixo está uma implementação de um método intertravado baseado em Interlocked.CompareExchange. É aconselhável que esse código use uma SpinWaitrotação antes de reiterar? public static bool AddIfLessThan(ref int location, int value, int comparison) { int currentValue; do { currentValue =...

Com base no meu entendimento, dado um array C #, o ato de iterar sobre o array simultaneamente de vários threads é uma operação segura para threads. Ao iterar sobre a matriz, quero dizer a leitura de todas as posições dentro da matriz por meio de um loop antigo simplesfor . Cada thread está...

O código abaixo produz um aviso ao executar com desinfetante de threads no macOS. Não consigo ver onde está a corrida. O bloco de controle shared_ptr e weak_ptr é seguro para threads, e empurrar e saltar do std::queueé feito com um bloqueio mantido. #include <future> #include...

Estou escrevendo um aplicativo de back-end no Kotlin. Para acelerar, atualmente estou confiando no RxKotlin no servidor para executar paralelamente tarefas de E / S, como chamadas de banco de dados e API. O código geralmente se parece com isso. val singleResult1 = Single.fromCallable{...

Pensei entender o padrão de espera assíncrona e a Task.Runoperação. Mas estou me perguntando por que, no exemplo de código a seguir, awaitele não é sincronizado novamente com o thread da interface do usuário depois de retornar da tarefa concluída. public async Task InitializeAsync() {...

Estou tendo problemas com o de Haskell bracket: ao ser executado dentro de um segundo argumento de um segmento bifurcado (usando forkFinally) bracket, o cálculo que libera recursos não é executado quando o programa termina. Aqui está o código que ilustra o problema (sei que, nesse caso específico,...

Como posso atribuir os membros de um vetor com um tipo atômico? #include <iostream> #include <thread> #include <vector> using namespace std; int main() { vector<atomic<bool>> myvector; int N=8; myvector.assign(N,false);

Quero escrever um programa cujo thread principal bifurque um novo thread para computação e aguarde que ele termine por um período de tempo. Se o encadeamento filho não for concluído no tempo determinado, o tempo limite será excedido e eliminado. Eu tenho o seguinte código para isso. import...