java.util.concurrent

    0熱度

    1回答

    我有使用ExecutorService調度任務的方法。我需要在一段時間後終止任務。我怎樣才能指定這樣的時間? 編輯: 我等待的時間X量的資源可用,而不是無限期的等待之後應該終止一個進程。

    0熱度

    1回答

    使用shutdownNow時。如果我使用Futures像 List<Future<String>> results = executorService.invokeAll(tasks); 或 Future<String> res = executorService.submit(new SingleWorker()); System.out.println(res.get()); 系統等

    0熱度

    1回答

    在ExecutorService的,我怎麼能組的所有線程處理特定課程ID,然後在一個線程中完成的過程,當然ID,請關閉所有其它線程這是在此過程中ID的過程? 能夠處理過程ID,直到一個線程結束處理的線程數,不是一個固定的數目。 更新: 因此,任何線程進入處理此過程中,我將它們添加到一個靜態集合。 假設爲courseid1,線程1最初處理, List l1 = new ArrayList(); l

    0熱度

    2回答

    在提交給執行程序服務(具有無限隊列的單線程)後是否可以修改可運行對象? 例如: public class Test { @Autowired private Runner userRunner; @Autowired private ExecutorService executorService; public void init() {

    0熱度

    1回答

    假設有一個線程池在具有4個CPU的計算機上運行,​​並且我想對該池執行加載動態控制。當有一些線程在池中運行時,是否可以更改corePoolSize?也就是說,當負載較低時,最多允許2個線程同時運行,但當負載較高時,允許4個線程。如果沒有,是否有適當的解決方案?

    0熱度

    1回答

    這是一個有效的代碼來寫,如果我想避免不必要的包含調用? 我希望避免每次調用都包含調用,因爲這是對時間敏感的代碼。 cancelretryCountMap.putIfAbsent(tag,new AtomicInteger(0)); count = cancelretryCountMap.get(tag).incrementAndGet(); if(count > 10){ ///ab

    2熱度

    3回答

    看到下面的代碼,這讓我感到困惑,在類DynamicPropertyFactory中,它鎖定了ConfigurationManager.class,正如我的理解,鎖只能在類或實例本身中使用。如何理解這一點? public class *DynamicPropertyFactory*{ public static *DynamicPropertyFactory* initWithConfi

    0熱度

    1回答

    我們知道這段代碼: Await.result(someFuture, Duration.Inf) 如果我把時間的有限值,例如3秒,一旦過期,它拋出TimeoutException異常。 Duration.Inf如何,恐怕應用程序掛起。使用Duration.Inf的最佳做法是什麼?

    -1熱度

    1回答

    我想在新線程中創建一個計數器,該線程有一個方法來在線程運行時獲取計數器的值。我怎樣才能以簡單的方式做到這一點?

    1熱度

    3回答

    我有一個ConcurrentHashMap和一個方法,在地圖中放入一個字符串,然後我根據插入的值在一個同步塊中執行一些操作。 putIfAbsent返回與指定鍵關聯的先前值,或者null如果沒有映射的關鍵 - 根據官方文檔 但是也有一些基於putIfAbsent是否返回空執行2個行動或不。 現在這裏是訣竅。我想要第一個動作(當putIfAbsent返回null)首先被執行,並且所有其他線程被擱置。