場景:發簡訊,當有資料量龐大的簡訊需要傳送時,可以採用多執行緒的方式分批處理以提高效率,但執行緒要控制合適的數量,否則會極大消耗cpu資源
上**:
建立分頁類pageutil
建立實現runnable介面的執行緒類testthread/**
* 分頁
* @param list 切割資料集合
* @param pagesize 每頁記錄數
* @param * @return
*/public static list> splitlist(listlist, int pagesize)
if ((j + 1) == ((j + 1) * pagesize))
}listarray.add(sublist);
}return listarray;
}
建立實體類userentitypublic class testthread implements runnable
@override
public void run() catch (interruptedexception e)
system.out.println("name:"+thread.currentthread().getname()+userentity.tostring());}}
}
建立主類batchthreadpublic class userentity
public userentity(string userid, string username)
public string getuserid()
public void setuserid(string userid)
public string getusername()
public void setusername(string username)
@override
public string tostring() ';}}
結果:public class batchthread
}public static listinituser()
return userentitylist;}}
java批量執行之分批處理
相關 在處理一些與資料庫相關的操作的時候,通常把一些操作合併能夠起到優化的效果,並且數量越大,批量執行的效率比一條一條執行的效率要快的多。比如有十條資料單條執行需要操作十次資料庫,批量的話執行一次資料庫的操作就可以。對應的sql語句 單次 insert into table name 列1,列2,v...
如何區分批處理和流處理?
資料可以抽象成兩種型別 無邊界資料 和 有邊界資料 無邊界資料,是一種不斷增長可以說是無限的資料集,這類資料無法判斷何時終止,如 電商交易資料 有邊界資料,是一種有限的資料集,如 常見的儲存好的資料 從無邊界資料按時間視窗提取部分資料,就是有邊界資料,所以,有邊界資料可以看做是無邊界的子集 在處理大...
大批量資料分批處理的推薦方式
對大批量資料進行增刪改操作時,比較推薦以下方式。該方式通過先取出所有欲處理的資料,然後將該資料分批處理。而不是通過limit的方式進行分批處理。相對於limit的好處是 如果limit第一批資料沒有全部更新,第二次limit取數的時候,可能會把第一次取到的資料再取一次。這樣就會重複處理。listli...