java-threads

0熱度

1回答

我有一個for循環創建了幾個AsyncTasks。存在大量的data，for循環處理每個數據並使用該數據調用執行程序。 AsyncTask對這些數據做了一些深入的處理，這些代碼對於小數據集來說工作得非常好，即數據數組足夠小以至於不會創建太多的線程。 for(Data datum: data) { new SomeAsyncDataTask(datum, this).executeOnE

1熱度

1回答

OCJP轉儲線程同步方法

嗨我正在SCJP轉儲，但現在我有一個問題。這裏是問題： void waitForSignal(){ Object obj = new Object(); synchronized(Thread.currentThread()){ obj.wait(); obj.notify(); } } 哪一種說法是正確的？ A.此代碼可以拋出一個Int

-2熱度

1回答

OCJP Dumps Thread

任何人都可以幫助我解決以下問題嗎？ public class Starter extends Thread{ private int x=2; public static void main(String[] args) throws Exception{ new Starter().makeItSo(); } public Starter(){

1熱度

3回答

簡單的Ping Pong Java線程

我正在嘗試使2個線程一個Ping和一個Pong。這個想法是Ping應該始終執行。我正在使用同步方法。我不確定這裏的代碼有什麼問題。它看起來像它應該工作。我已經閱讀了很多文檔。所以如果你有任何你認爲會有幫助的東西，我會很樂意閱讀它。我相信這很簡單。任何幫助表示讚賞 class Ping extends Thread { private Table table; private S

0熱度

1回答

轉換爲ExecutorService的

我有其中消費者/生產者程序：將被處理項（字符串）進入一個的BlockingQueue 我實例化來自BlockingQueue的執行取（）的螺紋固定數量的然後處理這些字符串。的處理線程是這個類的實例： class ProcessingThread extends Thread { private void process(String s) { (big method w

0熱度

1回答

爲什麼使用線程來調用類的構造函數？

我在閱讀JMS書時遇到了一個問題。以下是代碼。我的問題是與線程有關，所以我刪除了不必要的JMS代碼。 public class MessageConsumer implements MessageListener{ public MessageConsumer(){ //Constructor //configure JMS Connections } @Override

1熱度

1回答

3高頻率運行的線程使用相同的變量

我正在開發一個android應用程序，它在高頻率接收來自ble通知的數據，在屏幕上打印數據並將數據發送到其他外圍設備。這是我的情況： onCharacteristicChanged回調接收稱爲「值」一個字節數組爲10Hz並且在一些浮動解包數據和int變量具有相關聯的處理程序handlerThread每30hz啓動一次Runnable 。這可運行使用從值解壓的變量，在一些變量和sendbro

0熱度

2回答

使用ThreadPool按順序執行類似任務

我想要一個ThreadPool執行客戶訂單，多個訂單應該被並行處理，但是對於相同的客戶訂單應該按照生成的順序進行處理。這意味着如果有任何線程已經處理了customerA訂單，那麼沒有其他線程可以處理CustomerA的下一個訂單，直到處理完第一個訂單。是否有任何ThreadPool實現爲我的情況提供服務？

1熱度

1回答

ExecutorCompletionService等待最多n秒完成

我正在使用ExecutorCompletionService提交幾個任務。然後我想等待最長時間，例如5秒，然後停止處理。 ExecutorService executorService = Executors.newFixedThreadPool(10); CompletionService<String> completionService = new ExecutorCompletionS

1熱度

3回答

爲什麼我的多線程程序按順序執行？

以下程序不應該按順序執行，但它仍在執行。 class A extends Thread { public void run() { for(int i=0; i<=5; i++) { System.out.println("Thread A : "+i); } System.out.println("exit f