多线程中的实例变量行为

Question

我正在尝试运行具有 4 个线程的程序。我想知道线程中实例变量的行为。在这种情况下，我需要将一个值传递给该方法。所以，我这样做是为了传递值并将其用于进一步处理。

@Component
class ThreadExample implements Runnable
{
    String file;

    public void setFile(String file)
    {
       this.file = file;
    }
    @override
    public void run()
    {
       readFile(file);
    }
    public void readFile(String fileName)
    {  
        //logic for reading file
    }
}

@component
class ThreadCall
{
    @Autowired
    ThreadExample ex;

     public void testThread()
     {
        ExecutorService executor2 = Executors.newFixedThreadPool(4);
        getFiles()
          .stream()
          .forEach(f-> {
               ex.setFile(f);
               executor2.submit(ex);                             
           });
     }

}

getFiles() api 返回文件名列表。我正在尝试在Spring 中进行操作。 在这里，4 个线程将同时工作。对象ex 是autowired，所以它只会被实例化一次。

file 变量值会如何影响？

我在想，一个线程会尝试通过setFile(file) 设置文件，然后在readFile 中使用它之前，它会被另一个线程更改。

如何解决这个问题？如何在多线程中传递值？ 如果我将'file'设为volatile，我的问题会得到解决吗？

Answer 1

这里：

@Component
class ThreadExample implements Runnable
{
    String file;

    public void setFile(String file)

和

对象 ex 是自动装配的，因此它只会被实例化一次。

那是行不通的。你有：

executor2.submit(ex);      

您将 same 对象传递给应该并行执行特定操作的多个任务。更糟糕的是，您将不同的值推送到该单个对象中，并且以某种方式神奇地期望每个任务都能看到您希望它看到的值。会发生什么：这些事情发生在不同的线程上，所以结果（可能）是完全随机的，也就是不确定的。

长话短说：当您有多个“事情”需要完成时，随着时间的推移，您就不能使用“类似单例”的容器来调度您的参数。 volatile 对此无济于事，一点也不。

答案是：为了使这个工作，ThreadExample 不能是“单例”，所以将其变成单例的 @Component 注释必须消失。如果这样做与您的其他设计理念“冲突”，那么您必须退后一步并重新设计您的设计。

Answer 2

您必须将 ThreadExample 作为原型 bean。

@Component
@Scope("prototype")
class ThreadExample implements Runnable
{
    String file;

    public void setFile(String file)
    {
       this.file = file;
    }
    @Override
    public void run()
    {
       readFile(file);
    }
    public void readFile(String fileName)
    {  
        //logic for reading file
    }
}

那么你必须注入应用程序上下文，而不是在 ThreadCall 中注入 ThreadExample bean：

@Component
class ThreadCall
{
    @Autowired
    ApplicationContext context;


     public void testThread()
     {
        ExecutorService executor2 = Executors.newFixedThreadPool(4);
        getFiles()
          .stream()
          .forEach(f-> {
            ThreadExample ex= context.getBean(ThreadExample.class);   
               ex.setFile(f);
               executor2.submit(ex);                             
           });
     }

}

当你调用这段代码时，基本上每个 ThreadExample 都会是一个新的 bean。