自定义线程池-线程类和任务类代码实现
生活随笔
收集整理的這篇文章主要介紹了
自定义线程池-线程类和任务类代码实现
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
自定義線程池-實現步驟
1:編寫任務類(MyTask),實現Runnable接口;
2:編寫線程類(MyWorker),用于執行任務,需要持有所有任務;
3:編寫線程池類(MyThreadPool),包含提交任務,執行任務的能力;
4:編寫測試類(MyTest),創建線程池對象,提交多個任務測試;
package com.leon.demo01; /*需求:自定義線程池練習,這是任務類,需要實現Runnable;包含任務編號,每一個任務執行時間設計為0.2秒*/ public class MyTask implements Runnable{private int id;//由于run方法是重寫接口中的方法,因此id這個屬性初始化可以利用構造方法完成public MyTask(int id) {this.id = id;}@Overridepublic void run() {String name = Thread.currentThread().getName();System.out.println("線程:"+name+" 即將執行任務:"+id);try {Thread.sleep(200);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("線程:"+name+" 完成了任務:"+id);}@Overridepublic String toString() {return "MyTask{" +"id=" + id +'}';} } package com.leon.demo01;import java.util.List;/*需求:編寫一個線程類,需要繼承Thread類,設計一個屬性,用于保存線程的名字;設計一個集合,用于保存所有的任務;*/ public class MyWorker extends Thread{private String name;//保存線程的名字private List<Runnable> tasks;//利用構造方法,給成員變量賦值public MyWorker(String name, List<Runnable> tasks) {super(name);this.tasks = tasks;}@Overridepublic void run() {//判斷集合中是否有任務,只要有,就一直執行任務while (tasks.size()>0){Runnable r = tasks.remove(0);r.run();}} }?
總結
以上是生活随笔為你收集整理的自定义线程池-线程类和任务类代码实现的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 自定义线程池-参数设计分析
- 下一篇: 自定义线程池-线程池类和测试类编写