java - fo循环中增加Runnable线程

Question

1 我有一个程序需要在for 循环中增加 Runnable，现在发现他执行的顺序是从上往下 ，不是多线程的方式执行

2 代码如下
public void addUserACard() {

    
    ThreadLbData tLbData = null;
    DbBean dbBean = null ;
    
    List<DataBase> listData = dataDAO.findHql(" from DataBase where state = '1'  order by createDate desc ");
    DataBase data = null ;
    if(listData != null && listData.size()> 0){
        for (int i = 0; i < listData.size(); i++) {
            data = listData.get(i);
            dbBean =  createDbBean(data);
            tLbData = new ThreadLbData(dbBean);
            tLbData.run();
        }
    }
}

}

@SuppressWarnings("unchecked")
public class ThreadLbData implements Runnable {

private DbBean dataBase;
private Map map = new HashMap();
private static ConnectionPools connectionPools = ConnectionPools.getInstance();

public ThreadLbData(DbBean dataBase) {
    this.dataBase = dataBase;
}



public void run() {
    
    Connection conn = connectionPools.getConnectionOracle(); // 获得JDBC链接;
    try {
        String lbMaxId = this.getSynLogMaxId(dataBase, conn);
        Map map = getLbDate(lbMaxId);
        saveAll((List<ReaderCard>) map.get("listCard"), (List<Userinfo>)   map.get("listUser"), conn);
    } catch (Exception e) {
        e.printStackTrace();
    }finally{
        connectionPools.close(null, null, conn);
    }
}

}

3 想让大神帮我看看，线程的run能不能并行，并且帮我改进，跪谢！

Answer 1

Utilisez le pool de threads !

private ExecutorService executorService = Executors.newFixedThreadPool(10);
public void addUserACard() {
    
    ThreadLbData tLbData = null;
    DbBean dbBean = null ;
    
    List<DataBase> listData = dataDAO.findHql(" from DataBase where state = '1'  order by createDate desc ");
    DataBase data = null ;
    if(listData != null && listData.size()> 0){
        for (int i = 0; i < listData.size(); i++) {
            data = listData.get(i);
            dbBean =  createDbBean(data);
            executorService.execute(tLbData);
        }
    }
}

---

private ExecutorService executorService = Executors.newFixedThreadPool(10);

Le Executors.newFixedThreadPool(10) ci-dessus crée un pool de threads avec une taille fixe de 10.
puis le soumet via executorService.execute( Runnable runnable) A tâche, de sorte qu'un maximum de 10 tâches puissent être exécutées en parallèle. Si davantage de threads parallèles sont requis, alors les paramètres de Executors.newFixedThreadPool(threadCount) peuvent être définis plus grands.

---

Je veux me plaindre, vous auriez dû confondre l'interface Runnable et la classe Thread, non ? Une classe qui implémente l'interface Runnable ne signifie pas qu'elle s'exécute dans un nouveau thread. Vous devez explicitement soumettre le Runnable au nouveau thread. . Exécution, telle que executorService.execute(runnable) ou new Thread(runnable).start().

.

Answer 2

La méthode run ne peut pas être appelée directement, le thread doit être exécuté via la méthode Thread.start. Il n'y a aucune différence entre appeler directement la méthode run et appeler la méthode ordinaire.

new Thread(tLbData).start()