concurrency

5calore

3risposta

In che modo DelegatingVehicleTracker (p. 65 Goetz) restituisce una visualizzazione "live"?

A pagina 65 e 66 di Java Concurrency in Practice Brian Goetz elenca il seguente codice: @ThreadSafe public class DelegatingVehicleTracker { private final ConcurrentMap<String, Point> locations; pri

7calore

4risposta

Timeout per WaitGroup.Wait()

Qual è un modo idiomatico per assegnare un timeout a WaitGroup.Wait()? Il motivo per cui voglio farlo, è quello di salvaguardare il mio 'scheduler' da potenzialmente in attesa di un 'operaio' errante

5calore

1risposta

Qual è la differenza tra il multithreading temporale e il super-threading?

Ci sono due termini: Temporal multithreading: In grana fine multithreading temporale, il principale gasdotto processore può contenere più thread, con contesto interruttori efficacemente intervengono f

11calore

1risposta

PostgreSQL - implementazione di una coda affidabile

Sto cercando di implementare una coda affidabile con più writer e più lettori utilizzando il database Postgres. Come evitare le righe mancanti quando un lettore di code esegue la scansione di una tabe

6calore

1risposta

Matrice multithread di array?

devo una struttura di dati che consiste di 1.000 elementi dell'array, ogni elemento della matrice è una matrice minore di 8 interi: std::array<std::array<int, 8>, 1000> La struttura di dati contiene

5calore

1risposta

È volatile necessario, in caso di accesso solo sincronizzato

La variabile emitting può essere volatile? il metodo emit() viene chiamato da diversi thread ed emette deve essere visibile. Ma è accessibile solo nei blocchi synchronized. Gli // ... sono posti in cu

6calore

1risposta

Concorrenza di multiprocessing di Python utilizzando Manager, Pool e un elenco condiviso non funzionante

Sto imparando il multiprocessing di Python e sto tentando di utilizzare questa funzione per compilare un elenco con tutti i file presenti in un sistema operativo. Tuttavia, il codice che ho scritto è

8calore

2risposta

Come comporre due attività parallele per annullare un'attività se un'altra fallisce?

Vorrei implementare la mia elaborazione asincrona con scalaz.concurrent.Task. Ho bisogno di una funzione di (Task[A], Task[B]) => Task[(A, B)] per restituire un nuovo compito che funziona come segue:

14calore

4risposta

Seleziona query salta i record durante gli aggiornamenti simultanei

Ho una tabella elaborata contemporaneamente da N thread. CREATE TABLE [dbo].[Jobs] ( [Id] BIGINT NOT NULL CONSTRAINT [PK_Jobs] PRIMARY KEY IDENTITY, [Data] VARBINARY(MAX) NOT NULL,

6calore

1risposta

Bloccaggio con doppia verifica con HashMap normale

Torna alla concorrenza. Ormai è chiaro che per il double checked locking funzionare la variabile deve essere dichiarata come volatile. Ma allora cosa succederebbe se il doppio controllo fosse usato co