您好,登錄后才能下訂單哦!
這篇文章將為大家詳細講解有關Java中怎么利用多線程處理任務,文章內容質量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關知識有一定的了解。
1.直接傳遞一批任務給到多線程處理方法,返回處理結果
代碼如下:
/** * Created with IntelliJ IDEA. * 測試多線程處理任務 * className: TaskMulThreadServiceTest * * @version 1.0 * Date Time: a *@author: ddys */ public class TaskMulThreadServiceTest extends TestCase implements ITaskHandle<String,Boolean>{ public void testExecute() throws Exception { String [] taskItems = new String[100]; for (int i=0;i<100;i++){ taskItems[i]="任務"+i; } IMulThreadService<String,Boolean> mulThreadService = new TaskMulThreadService(this); long start = System.currentTimeMillis(); List<Boolean> result = mulThreadService.execute(taskItems); for (Boolean e : result){ if(!e){ System.out.println("任務處理失敗"); } } System.out.println("所有任務處理完成,耗時"+(System.currentTimeMillis()-start)+",任務成功數"+result.size()); } /** * Created with IntelliJ IDEA. * 執行任務,返回所有執行的結果 * className: TaskMulThreadService * * @author: ddys * @version 1.0 * Date Time: */ public Boolean execute(String s) { System.out.println(Thread.currentThread().getId()+"線程正在處理"+s); return true; } }
2.附帶一個查詢任務的方法,實現這個查詢任務方法和業務處理方法,然后執行返回處理結果
代碼如下:
ate Time: a *@author: XWK */ public class SelectTaskMulThreadServiceTest extends TestCase implements ISelectTask<String,Boolean>{ public void testExecute() throws Exception { IMulThreadService<String,Boolean> mulThreadService = new SelectTaskMulThreadService(this); long start = System.currentTimeMillis(); List<Boolean> result = mulThreadService.execute(); for (Boolean e : result){ if(!e){ System.out.println("任務處理失敗"); } } System.out.println("所有任務處理完成,耗時"+(System.currentTimeMillis()-start)+",任務成功數"+result.size()); } /** * Created with IntelliJ IDEA. * 執行任務,返回所有執行的結果 * className: TaskMulThreadService * * @author: ddys * @version 1.0 * Date Time: */ public Boolean execute(String s) { System.out.println(Thread.currentThread().getId()+"線程正在處理"+s); return true; } /** * @param 'a 傳遞參數 * @return a 回類型 * @throws * @Title: a * @Description: 獲取一批任務 * @author ddys * @date 2015-11-15 21:09 */ public String[] getTaskItem() { String [] taskItems = new String[100]; for (int i=0;i<100;i++){ taskItems[i]="任務"+i; } return taskItems; } }
關于Java中怎么利用多線程處理任務就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。