eu tenho o seguinte problema com concorrencia usando Thread.
O código abaixo deve Pegar o ultimo número de uma coluna de uma tabela e adicionar +1 para salvar novamente no banco, o problema é esse número não pode se repetir e por causa da thread ele esta se repetindo.
O banco e isso .<br>
<b>------
---- Items -------------------<br>
id  | numeroCupom | qtdItem<br>
=====================</b><br>
Não posso usar auto_incremente em qtdItem já que se o número do cupom mudar a quatidade de items tem que ser zerada. O professor que passou esse exercicio disse que tem duas maneiras de consertar usando o select for isert e outra forma que não lembro, eu tentei com a select for insert porém continuou inserindo qtdItem duplicadas.
O código atual insere algo no banco tipo

--------------------------------------
---- Items ---------------------------<br>
id  | numeroCupom | qtdItem

<b>1   | 5 |    1</b><br>
<b>2   | 5 |    2</b><br>
<b>3   | 5 |    2</b><br>
O correto seria
--------------------------------------
---- Items ---------------------------<br>
id  | numeroCupom | qtdItem

<b>1 |           5          |    1</b><br>
<b>2   |           5          |    2</b><br>
<b>3   |           5          |    3</b><br>




    /*
     * To change this license header, choose License Headers in Project Properties.
     * To change this template file, choose Tools | Templates
     * and open the template in the editor.
     */
    package concorrencia;
    
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    import java.util.logging.Level;
    import java.util.logging.Logger;
    
    
    
    /**
     *
     * @author Francisco
     */
    public class Concorrencia {

    
    private static Connection conectar(){
        try {
            Class.forName("com.mysql.jdbc.Driver");
            return DriverManager.getConnection("jdbc:mysql://localhost/fiscal", "jp", "");
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(Concorrencia.class.getName()).log(Level.SEVERE, null, ex);
        } catch (SQLException ex) {
            Logger.getLogger(Concorrencia.class.getName()).log(Level.SEVERE, null, ex);
        }
        return null;
    }
    
    private static int getProximoId(Connection con, int cupomId) throws SQLException{
        PreparedStatement stmt = con.prepareStatement("select max(nr_item) from item_cupom where cupom_id = ?");
        stmt.setInt(1, cupomId);
        ResultSet rs = stmt.executeQuery();
        try{
            if(rs.next()){
                return rs.getInt(1) + 1;
            }else{
                return 1;
            }
        }finally{
            rs.close();
            stmt.close();
        }
    }
    
    public static void inserirItem(Connection con, int cupomId, boolean demorar) throws SQLException, InterruptedException{
        int nrItem = getProximoId(con, cupomId);
        if(demorar){
            Thread.sleep(200);
        }
        PreparedStatement pstmt = con.prepareStatement("insert into item_cupom(cupom_id, nr_item) values(?, ?);");
        pstmt.setInt(1, cupomId);
        pstmt.setInt(2, nrItem);
        pstmt.execute();
        pstmt.close();
    }
    
    private static boolean seraQueVaiDemorar(){
        double valor = Math.random();
        return valor > 0.8;
    }
    
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        Connection con = conectar();
        
        for (int i = 0; i < 2; i++) {
            new Thread(){
                @Override
                public void run() {
                    for(int i = 0; i < 300; i++){
                        try {
                            inserirItem(con, 5, seraQueVaiDemorar());
                        } catch (Exception ex) {
                            Logger.getLogger(Concorrencia.class.getName()).log(Level.SEVERE, null, ex);
                        }
                    }
                }
                
            }.start();
        }
    }   
    }