Java - 用循环填充线程的 ArrayList

Question

这个问题可能很容易回答，但我就是不明白。 我减少了我的问题，直到留下一小段代码以找到这个问题的“起源”： 我正在尝试用循环填充线程的 ArrayList。

public static int u=0;

public void test(){
    while (u <10) {
        synchronized(threadList){
            threadList.add(u, new Thread(){                
                @Override public void run(){                    
                    System.out.println("Thread at Index: " + u);                     
                } 
            });
        }
        u++;            
    }

    threadList.get(2).start();    
}

在最后一行中，我想通过在索引“2”处启动线程来测试上面的循环。 我希望控制台显示“索引处的线程：2”，但显示的是： “索引处的线程：10” 无论我在“.get(int)”方法中写入哪个整数，我都会收到索引'10'。

这是为什么呢？以及如何解决这个问题？

线程的创建似乎工作......整数'u'是问题吗？

感谢任何形式的帮助！ 提前致谢！

Answer 1

当您在 run 方法中引用 u 时

@Override public void run(){                    
    System.out.println("Thread at Index: " + u);                     
} 

检索u 的当前值。在循环结束和线程运行时，该值为10。

试试下面的

public static int u = 0;

public void test(){
    while (u <10) {
        synchronized(threadList){
            threadList.add(u, new Thread(){     
                int i = u;

                @Override public void run(){                    
                    System.out.println("Thread at Index: " + i);                     
                } 
            });
        }
        u++;            
    }

    threadList.get(2).start();    
}

在您的匿名 Thread 类中，您将实例字段 i 设置为调用构造函数时 u 的值，并在执行 run() 时打印该值。

您在尚未执行的上下文（线程）中引用u。当 run() 方法最终被调用时，程序将评估变量 u，但在程序执行的那一刻，它的值将是 10。如果你执行上述操作，变量 @987654334 @ 将在那个确切时刻保存该值。这是因为当新的Thread 启动并执行时，会发生字段初始化，并且会立即评估u。

Answer 2

试试这两种方法：

package com.test;

import java.util.ArrayList;

public class TestThread5 {
    public static int u=0;
    public ArrayList<Thread> threadList = new ArrayList<>();
    public void test() throws InterruptedException{
        while (u <10) {
            synchronized(threadList){
                threadList.add(u, new Thread(){                
                    @Override public void run(){                    
                        System.out.println("Thread at Index: " + u);                     
                    } 
                });
            }
            u++;            
        }
        for ( u = 0; u < 10; u++) {
            Thread thread = threadList.get(u); 
            thread.start();
            thread.join();
        }
       // threadList.get(2).start();    
    }
    public static void main(String[] args) throws InterruptedException {
        new TestThread5().test();
    }
}

和

package com.test;

import java.util.ArrayList;
import java.util.Iterator;

public class TestThread4 {
    public  int u=0;
    public ArrayList<Thread> threadList = new ArrayList<>();
    public void test() throws InterruptedException{
        while (u <10) {
            synchronized(threadList){
                threadList.add(u, new MyThread(u));
            }
            u++;            
        }
        for(Thread thread :threadList){
            thread.start();
            thread.join();
        }
       // ((Thread) threadList.get(2)).start();    
    }
    public static void main(String[] args) throws InterruptedException {
        new TestThread4().test();
    }
}
class MyThread extends Thread{
    private int u;
    public MyThread(int u){
        this.u = u;
    }
    @Override
    public void run() {
        System.out.println("Thread at Index: " + u);  
    }

}

Answer 3

    while (u <10) {
        synchronized(threadList){

            final int u_final = u;

            threadList.add(u, new Thread(){                
                @Override public void run(){                    
                    System.out.println("Thread at Index: " + u_final );
                } 
            });
        }
        u++;            
    }

使用final 变量，很清楚它的值是什么，因为它永远不会改变。