Tag: java.util.concurrent

Arbeite ich an einer simulation system, wo bei jedem Zeitschritt, ich habe zu simulieren viele Modelle. Habe ich eine FixedThreadPool, um die Geschwindigkeit der Berechnung: ExecutorService executor = Executors.newFixedThreadPool(nThread); for (Model m : models) { executor.execute( m.simulationTask()

meinen code werfen Folgen Ausnahme: java.util.ConcurrentModificationException at java.util.LinkedList$ListItr.checkForComodification(LinkedList.java:761) at java.util.LinkedList$ListItr.next(LinkedList.java:696) at java.util.AbstractCollection.addAll(AbstractCollection.java:305) at java.util.LinkedHashSet.<init>(LinkedHashSet.java:152) ... Möchte ich ein ConcurrentLinkedHashSet um es zu beheben, aber ich fand nur ConcurrentSkipListSet im java.util.concurrentist dies TreeSet, nicht LinkedHashSet jede easies Weise

Ich habe eine ThreadPoolExecutor und ich, Einreichen einer Aufgabe zu. private ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1)); Dieser code legt die Runnable zu den ThreadPoolExecutor. protected void waitAndSweep(final String symbol) { runnable =

Wie werden Sie ausführen, die Drei threads nacheinander? Für zB. Thread1, Thread2 Verzahnt, Thread3. Es ist nicht möglich, übergeben Sie die Referenz von einem Thread zum anderen und aufrufen von run () - Methode. Also code sollte

Habe ich ein Szenario, wo ich auf ausführen 5 thread asynchron zum gleichen aufrufbar. Soweit ich das verstehe, gibt es zwei Optionen: 1) mit submit(Callable) ExecutorService executorService = Executors.newFixedThreadPool(5); List<Future<String>> futures = new ArrayList<>(); for(Callable callableItem: myCallableList){

Habe ich bemerkt, dass einige der Befehle in meine Bewerbung schlägt mit Caused by: ! com.netflix.hystrix.exception.HystrixRuntimeException: GetAPICommand timed-out and no fallback available. out: ! at com.netflix.hystrix.HystrixCommand.getFallbackOrThrowException(HystrixCommand.java:1631) out: ! at com.netflix.hystrix.HystrixCommand.access$2000(HystrixCommand.java:97) out: ! at com.netflix.hystrix.HystrixCommand$TimeoutObservable$1$1.tick(HystrixCommand.java:1025) out: ! at

Kann ich Callable threads ohne ExecutorService? Wir können Instanzen von Runnable und Unterklassen von Thread ohne ExecutorService und dieser code funktioniert in der Regel. Aber dieser code funktioniert konsequent: public class Application2 { public static class WordLengthCallable

Den Java Tutorials für Lambda-Ausdrücke sagt Folgendes: Dieser Abschnitt beschreibt die features in Project Lambda, das darauf abzielt zur Unterstützung der Programmierung in einer multicore-Umgebung durch das hinzufügen von closures und damit verbundene features der Java-Sprache. Meine

Gemäß Abschnitt 6.3.2 von JCIP : Runnable ist eine ziemlich Einschränkung der Wasserentnahme; führen Sie können nicht einen Wert zurückgeben oder wegwerfen überprüft Ausnahme . run() können nicht einen Wert zurückgeben, da Ihr Rückgabetyp ist void, aber

Wenn der Rückgabewert nicht von Interesse ist, ist es (auch irrelevant in der Praxis) Unterschied zwischen AtomicInteger.getAndIncrement() und AtomicInteger.incrementAndGet() Methoden als Rückgabewert wird ignoriert? Ich denke da an Unterschiede, wie die mehr Redewendungen, sowie die weniger Last

Also ich habe ein Programm, dass threads erstellt (~5-150), die eine Reihe von Aufgaben. Ursprünglich habe ich eine FixedThreadPool weil eine ähnliche Frage vorgeschlagen, Sie waren besser geeignet, für mehr lebte Aufgaben und mit meiner sehr begrenzten

Sehe ich diese Umsetzung BlockingQueue und kann nicht verstehen, die Unterschiede zwischen Ihnen. Mein Fazit bisher: Ich nicht jemals brauchen SynchronousQueue LinkedBlockingQueue sorgt FIFO, BlockingQueue erstellt werden muss mit dem parameter true zu machen, FIFO SynchronousQueue bricht

Wenn wir einen ExecutorCompletionService wir unterbreiten eine Reihe von Aufgaben, wie Callables und erhalten das Ergebnis der Interaktion mit der CompletionService als queue. Aber es gibt auch die invokeAll von ExecutorService akzeptiert eine Collection Aufgaben und wir

java.util.concurrent - API stellt eine Klasse namens als Lock würde, was im Grunde serialisieren Sie das Steuerelement, um einen Zugang zu der kritischen Ressource. Es gibt Methoden, wie park() und unpark(). Können wir ähnliche Dinge tun, wenn

dies ist eine passage aus JavaDoc über ConcurrentHashMap. Es sagt retrieval-Operationen in der Regel nicht blockieren, so können überschneidungen mit den update-Operationen. Bedeutet das, dass die get() - Methode nicht thread-sicher? "Aber auch wenn alle Operationen thread-sicher

Zukunft.get(timeout) nicht zuverlässig werfen die TimeoutException, die nach dem angegebenen timeout. Ist das normal oder kann ich etwas tun, um diese zuverlässiger? Dieser test schlägt fehl auf meinem Rechner. Allerdings, wenn ich schlafen für 3000 statt 2000,

Ich habe ein Bedürfnis für einen Zähler des Typs long mit folgenden Anforderungen/Fakten: Inkrementieren der Zähler sollte so wenig Zeit wie möglich. Der Zähler wird nur geschrieben werden, um von einem thread. Lesung aus dem Zähler erfolgt

Ich Schreibe eine Anwendung, die liefert eine HashMap zu Benutzer. Benutzer der Verweis auf diese KARTE. Auf das backend, werde ich einige threads, die Aktualisierung der Karte. Was ich bisher getan habe? Habe ich gemacht alle backend-threads