Ce que je recherche, c'est un moyen compatible de configurer ou non l'utilisation d'un pool de threads. Idéalement, le reste du code ne devrait pas du tout être affecté. Je pourrais utiliser un pool de threads avec 1 thread mais ce n'est pas tout à fait ce que je veux. Des idées? ExecutorService...
Je recherche une implémentation ExecutorService qui peut être fournie avec un délai d'expiration. Les tâches soumises à ExecutorService sont interrompues si elles prennent plus de temps que le délai d’expiration. Mettre en œuvre une telle bête n'est pas une tâche si difficile, mais je me demande...
Je lis SIP-14 et le concept de Futureest parfaitement logique et facile à comprendre. Mais avez deux questions sur Promise: Le dit SIP Depending on the implementation, it may be the case that p.future == p. Comment se peut-il? Sont Futureet Promisenon deux types différents? Quand devrions-nous...
à partir de Rails 4 , tout devrait fonctionner dans un environnement threadé par défaut. Ce que cela signifie, c'est tout le code que nous écrivons ET TOUTES les gemmes que nous utilisons doivent êtrethreadsafe donc, j'ai quelques questions à ce sujet: Qu'est-ce qui n'est PAS thread-safe dans ruby...
Y a-t-il un avantage à utiliser java.util.concurrent.CountdownLatch au lieu de java.util.concurrent.Semaphore ? Pour autant que je sache, les fragments suivants sont presque équivalents: 1. Sémaphore final Semaphore sem = new Semaphore(0); for (int i = 0; i < num_threads; ++ i) { Thread t = new...
J'observe la visibilité croissante des langages de programmation fonctionnels et des fonctionnalités depuis un certain temps. Je les ai examinés et je n'ai pas vu la raison de l'appel. Puis, récemment, j'ai assisté à la présentation "Basics of Erlang" de Kevin Smith à Codemash . J'ai apprécié la...
http://msdn.microsoft.com/en-us/library/system.threading.semaphoreslim.aspx Pour créer un sémaphore, je dois fournir un nombre initial et un nombre maximum. MSDN déclare qu'un décompte initial est - Nombre initial de requêtes pour le sémaphore pouvant être accordées simultanément. Bien qu'il...
Dans la programmation de socket, vous créez un socket d'écoute, puis pour chaque client qui se connecte, vous obtenez un socket de flux normal que vous pouvez utiliser pour gérer la demande du client. Le système d'exploitation gère la file d'attente des connexions entrantes dans les coulisses....
Le javadoc pour SimpleDateFormat indique que SimpleDateFormat n'est pas synchronisé. "Les formats de date ne sont pas synchronisés. Il est recommandé de créer des instances de format distinctes pour chaque thread. Si plusieurs threads accèdent à un format simultanément, il doit être synchronisé en...
Je trouve souvent ces termes utilisés dans le contexte de la programmation simultanée. Sont-ils identiques ou différents?
Y a-t-il une bonne et courte explication du fonctionnement des acteurs par rapport aux threads? Un fil de discussion ne peut-il pas être considéré comme un acteur et envoyer des messages à d'autres fils? Je vois une différence, mais ce n'est pas si clair pour moi. Puis-je utiliser des acteurs dans...
Lors de la recherche sur l'utilisation des conseils de table mes , je suis tombé sur ces deux questions: Quels indices de verrouillage dois-je utiliser (T-SQL)? Quel est l'effet de HOLDLOCK sur UPDLOCK? Les réponses aux deux questions indiquent que lors de l'utilisation (UPDLOCK, HOLDLOCK) ,...
J'aime vraiment ces outils en ce qui concerne le niveau de concurrence qu'ils peuvent gérer. Erlang / OTP ressemble à une solution beaucoup plus stable mais nécessite beaucoup plus d'apprentissage et beaucoup de plongée dans le paradigme du langage fonctionnel. Et il semble qu'Erlang / OTP le rend...
Fermé . Cette question doit être plus ciblée . Il n'accepte pas les réponses actuellement. Vous souhaitez améliorer cette question? Mettez à jour la question afin qu'elle se concentre sur un problème uniquement en modifiant ce message . Fermé il y a 5 ans . Améliorez cette question J'ai récemment...
Dans une version antérieure à la sortie de go 1.5 du site Web Tour of Go , il y a un morceau de code qui ressemble à ceci. 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") } La...
Supposons que j'ai plusieurs futurs et que j'attende que l' un ou l' autre échoue ou que tous réussissent. Par exemple: Soit il y a 3 à terme: f1, f2, f3. Si f1réussit et f2échoue, je n'attends pas f3(et je renvoie l' échec au client). Si f2échoue pendant f1et f3est toujours en cours d'exécution,...
Tout en essayant de comprendre comment SubmissionPublisher( code source dans Java SE 10, OpenJDK | docs ), une nouvelle classe ajoutée à Java SE dans la version 9, a été implémentée, je suis tombé sur quelques appels d'API dont VarHandleje n'étais pas au courant auparavant: fullFence, acquireFence,...
J'ai besoin d'une sorte de service qui exécutera quelques tâches simultanément et dans un intervalle de 1 seconde pendant 1 minute. Si l'une des tâches échoue, je veux arrêter le service et toutes les tâches qui l'ont exécuté avec une sorte d'indicateur que quelque chose s'est mal passé, sinon si...
Les coroutines Kotlin offrent-elles des garanties de «survenance avant»? Par exemple, existe-t-il une garantie «passe avant» entre l'écriture mutableVaret la lecture ultérieure sur (potentiellement) un autre thread dans ce cas: suspend fun doSomething() { var mutableVar = 0
push_back , begin , end sont décrits comme sûrs simultanés dans https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrent-vector-class?view=vs-2019#push_back Cependant, le code ci-dessous s'affirme. Probablement parce que l'élément est ajouté mais pas encore initialisé. struct...