從不同線程填充數組

Question

我在編寫一個非常簡單的程序，它創建了幾個線程來發送併發請求到一個特定的URL。我測量並存儲響應時間。我遇到的問題是，雖然我創建了我的響應時間數組作爲靜態和最終，我存儲在此數組中的值只存在於我的一個生成的線程內。只要我退出循環並進入主線程，數組就是空的（包含0個值）。所以我的代碼片段中的總和總是爲零。我意識到我的錯誤可能是一個非常基本的錯誤，但不幸的是我無法在網上找到類似的主題。你能否指點我正確的方向？謝謝。

public class MyClass {  
static final long[] respTimes = new long[l]; 

public static void sendRequest() {...} 

public static void main(String[] args) throws Exception { 
    for(int i=0; i<l; i++) { 
     new Thread("" + i) { 
      public void run() { 
       long startTime = System.nanoTime(); 
       sendRequest(); 
       long estimatedTime = System.nanoTime() - startTime; 
       respTimes[i] = estimatedTime; 
      } 
     }.start(); 
    } 
     for(int i=0; i<l; i++) { sum += respTimes[i]; } 
} 

}

Answer 1

這不是問題。你的問題是在你有機會產生結果之前打印結果。這樣做：

Thread [] theThreads = new Thread[10]; 

for (...) { 
    theThreads[i] = new Thread() { ... }.start(); 
} 

// now make sure all the threads are done 
for (...) { 
    // this waits for the thread to finish 
    theThreads[i].join(); 
} 

// now print things out 

Answer 2

：O static final array？ O0是不能很好

嘗試通過構造函數傳遞數組的線程和主線程

http://en.wikipedia.org/wiki/Final_(Java)

最後一個變量只能分配一次創建它。

與常量的值不同，最終變量的值在編譯時不一定是已知的。

Answer 3

您可能正在經歷競賽狀況。 for循環在任何線程實際啓動和/或完成之前完成。

如果您使用的是JDK 1.5或更高版本，請使用java.lang.concurrent類進行研究。他們使這些類型的線程連接操作變得非常簡單。

HTH

Answer 4

因爲我有一個臨牀厭惡靜態方法：P和組織代碼的事情（也注意到你沒有處理出來send方法中的任何例外）

public class MultiClient 
{ 
    private long[] responseTimes = null; 
    private Throwable[] errors = null; 
    public MultiClient(int count) 
    { 
    responseTimes = new long[count]; 
    errors = new Throwable[count]; 
    } 
    protected void sendRequestWrapper(int index) 
    { 
    long startTime = System.nanoTime(); 
    try 
    { 
     //original send request 
     sendRequest(); 
    } 
    // optionally you may put a catch() here to process errors 
    catch(Throwable t) 
    { 
     errors[index] = t; 
    } 
    finally 
    { 
     //this will guarantee response times filled up even in case of 
     //sendRequest raising an exception 
     responseTimes[index] = System.nanoTime() - startTime; 
    } 
    } 
    public void doStuff() 
    { 
    Thread[] threads = new Thread[count]; 
    //separete create thread calls 
    for(int i = 0; i < threads.length; i++) 
    { 
     threads[i] = new Worker(i); 
    } 
    //... from start calls 
    for(int i = 0; i < threads.length; i++) 
    { 
     threads[i].start(); 
    } 
    // wait till all threads are done 
    for(int i = 0; i < threads.length; i++) 
    { 
     threads[i].join(); 
    } 
    } 
    private class Worker extends Thread 
    { 
    private int index = -1; 
    public Worker(int index) 
    { 
     super("worker "+index); 
     this.index = index; 
    } 
    public void run() 
    { 
     MultiClient.this.sendRequestWrapper(index); 
    } 
    } 
    public long[] getResponseTimes(){ return responeTimes; } 
    public Throwable[] getErrors(){ return errors; } 
    public boolean sendFailed(int indeX){ return errors[index] != null; } 

    public static void main(String[] args) 
    { 
    int count = ...; // get count from somewhere (cmd line, hard coded etc.) 
    MultiClient multiClient = new MultiClient(count); //create an array filler 
    multiClient.doStuff(); //this will block till all the threads are done 
    long[] responseTimes = multiClient.getResponseTimes(); 

    //do whatever you want with the response times 
    } 

}