Javaは：同期のスレッドで失敗

Question

I次のコードを持っている：

for (int iThreadCounter = 1; iThreadCounter <= CONNECTIONS_NUM; iThreadCounter++){ 
    WorkThread wt = new WorkThread(iThreadCounter); 
    new Thread(wt).start(); 
    m_arrWorkThreadsToCreate.add(wt); 
} 

これらのスレッドは、次のコードを呼び出します。

int res = m_spLegJoin.call(m_workTread, m_workTread.getConfId()); 

そして、これがLegJoinSpクラス内の呼び出し方法です：

public class LegJoinSp extends ConnEventSp { 

    private static final int _LEG_JOIN_ACTION_CODE = 22; 
    private static int m_nLegId = Integer.valueOf(IniUtils.getIniValue("General", "LEG_ID_START")); 
    private final Lock m_lock = new ReentrantLock(); 

    public int call(WorkThread a_workThread, String a_sConfId) { 

     synchronized (this) { 

      //m_lock.lock(); 
      m_nLegId++; 

      boolean bPass = false; 

      Log4jWrapper.writeLog(LogLevelEnum.DEBUG, "LegJoinSp - call", "a_workThread = " + a_workThread.getThreadId() + " a_sConfId = " + a_sConfId); 

      if (super.call(a_workThread, a_sConfId, _LEG_JOIN_ACTION_CODE, "" + m_nLegId) == 0) { 

       bPass = true; 

      } else { 
       bPass = false; 
      } 

      //m_lock.unlock(); 

      if (bPass) { 

       Log4jWrapper.writeLog(LogLevelEnum.DEBUG, "LegJoinSp - call", "a_workThread = " + a_workThread.getThreadId() + " a_sConfId = " + a_sConfId + " returned leg id " + m_nLegId); 

       return m_nLegId; 
      } else { 

       return -1; 
      } 
     } 

    } 

    public Lock getLock() { 
     return m_lock; 
    } 

} 

を

私はこのcall（）メソッドを呼び出す2つのスレッドを持っています。 あなたは、私は問題は（bPass）場合、私は最初のに到達したときということです

synchronized(this) 

と

m_lock.lock() and m_lock.unlock() 

の両方でメソッドをロックしようとしている見ることができるようにm_nLegIdが100 で開始されます内部コードは、m_nLegId値として102に自分のログに書き込みます。しかし、私はそれがm_nLegId ++のために101であることを期待しています。声明。 最初のスレッドの実行で同期ブロックが終了する前に、2番目のスレッドがコード内に入るようになっているようです。

どうすれば修正できますか？

は事は（あなたがこのにロックを適用して）あなたはすべてのスレッドで新しいオブジェクトを作成しているが、あなたはロックを適用する方法は、同じオブジェクトに適用されているあなたに

Answer 1

私の場合は、m_nLegIdがstatic fieldであり、クラスの代わりに現在のインスタンスのアクセスを同期しようとしているため、フィールドの同時変更を適切に防止できません。場合にはあなただけintの代わりに自分のフィールドにAtomicIntegerを使用することを検討して、カウンタが必要：

私が意味

synchronized (this) { 

はむしろ

synchronized (LegJoinSp.class) { 

NBであるべき。

Answer 2

ありがとうございます。
したがって、クラスレベルでロックを適用する場合は、静的オブジェクトを作成し、そのオブジェクトにロックを適用して達成することができます（コメントに基づいて問題を正しく理解した場合）