java 并发 - 同步块(synchronized block)

Question

我的代码中有一个不应该发生的线程问题 - 但确实发生了。所以我想做一些变通。我会尽量用简单的代码来解释我的问题——因为我遇到问题的代码又大又复杂所以简而言之，代码:

...................
..................
void createAndRunThreads(){
   List<Path> pathList = //read path from DB readPath();
   for(Path p : pathList){
      RunJob rj = new RunJob(p);
      Thred t = new Thread(rj);
      t.start();
   }
}

class RunJob implements Runnable {
   private Path path;
   private ExecuteJob execJob;

   public RunJob(Path path){
      this.path = path;
      this.execJob = new ExecuteJob();
   }

   public void run() {
      execJob.execute(path);
   }

}

class ExecuteJob {

   private static Job curentExecutingJob;

   public void execute(Path path){
      //here every thread should get different job list from others but this is not happening
      //so what happens eventually two threads are executing the same Job at once and it gets messy
      List<Job> jobList = getJobsFromPath(path);

      for(Job job : jobList) {
         curentExecutingJob=job;

         //work around that I'm trying to do. So if other thread tries to run the same job has to wait on lock(I dont know if this is posible do) 
         synchronized(curentExecutingJob){
            if(job.getStatus.equals("redy")){
               //do sum initialization 
               //and databese changes 
               job.run();
            }   
         }  
      }
   }

}

所以我担心的是这是否可行——我不知道锁中的对象是通过内存(需要是确切的对象)还是通过等于(在其上实现相等)进行比较

当静态 curentExecutingJob 成员在第一个线程中有一个值对象并在该对象上创建锁(在同步块(synchronized block)中)并且第二个线程更改该值并尝试进入同步块(synchronized block)时会发生什么(我的期望是是thread-2将继续执行并且只有当他将从数据库中获得与之前第一个线程获得它相同的作业时才会被阻塞)

不知道这种做法是否可行，是否有意义

两个线程正在运行方法内部的以下代码

1    Job j = getJobByIdFromDB(1111);
2    if(j.status.equals("redye")){
3        do staff
4        make database changes 
5        j.run();
6        j.state="running";
7    }

ThreadA 在 JVM 的第 3 行停止执行，其状态从运行更改为可运行，并设置为等待轮询。

ThreadB 由 JVM 提供机会，ThreadB 执行第 1、2、3、4、5、6 行，这是我不希望发生的。我希望第一个线程在第 2,3 行中输入代码之前完成，然后其他线程中的某个人有机会输入相同的代码

实现这个的问题是两个线程正在执行具有不同实例的示例方法，因此同步整个方法将无法工作 - 我还有其他代码在这个方法中执行，我不希望它同步到
那么我的问题有解决方案吗此外，如果我进行同步(this.class){}，它将失去多线程的好处和意义

Answer 1

问题是“currentExecutingJob”被定义为静态的，这意味着 ExecuteJob 的所有实例共享该变量的相同“实例”。此外，您在同步块(synchronized block)之外设置此变量的值，这意味着每个线程都将以不受控制的方式设置它。您的以下同步块(synchronized block)应该没有任何实际影响。

鉴于您的示例代码的编写方式，在我看来您不需要任何静态变量，也不需要任何同步，因为没有跨多个线程共享的资源。

但是，您在代码中的注释表明您希望防止两个线程同时执行同一个作业。您的代码没有实现这一点，因为没有比较正在运行的作业以查看是否正在运行相同的作业，即使有比较，您的 getJobsFromPath() 也需要构建一个作业列表，以便相同的对象实例当两个线程/路径遇到相同的“作业”时需要重用。

我在您的代码中没有看到任何这些。