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能不能并行,并且帮我改进,跪谢!
スレッドプールを使用してください!
リーリーリーリー
上記の Executors.newFixedThreadPool(10) は、固定サイズ 10 のスレッド プールを作成します。
その後、executorService.execute( Runnable runnable) を通じてタスクを送信すると、最大 10 個のタスクを並行して実行できます。より多くの並列スレッドが必要な場合は、Executors.newFixedThreadPool(threadCount) のパラメータを大きく設定できます。
文句を言いたいのですが、Runnable インターフェイスと Thread クラスを混同しているはずですよね? Runnable インターフェイスを実装するクラスは、それが新しいスレッドで実行されることを意味するものではなく、実行のために Runnable を新しいスレッドに明示的に送信する必要があります。たとえば、executorService.execute(runnable) または new Thread(runnable).start().
run メソッドを直接呼び出すことはできません。スレッドは Thread.start メソッドを通じて実行する必要があります。 run メソッドを直接呼び出すことと通常のメソッドを呼び出すことには違いはありません。
リーリー