Java多線程繼承Thread類詳解第1/2頁(yè)
更新時(shí)間:2016年06月19日 15:46:59 投稿:hebedich
Java多線程的兩種實(shí)現(xiàn)方式:繼承Thread類 & 實(shí)現(xiàn)Runable接口,今天我們來(lái)學(xué)習(xí)下繼承Thread類,希望大家能夠喜歡
調(diào)用方法:
/** * 點(diǎn)擊量/月(年)Thread */ public void yearlyClickThread() { // 獲取參數(shù) String year = getPara("year"); // 統(tǒng)計(jì)數(shù)據(jù)集X List<String> xList = new ArrayList<String>(); xList.add("January"); xList.add("February"); xList.add("March"); xList.add("April"); xList.add("May"); xList.add("June"); xList.add("July"); xList.add("August"); xList.add("September"); xList.add("October"); xList.add("November"); xList.add("December"); // 統(tǒng)計(jì)數(shù)據(jù)集Y List<Integer> yList = new ArrayList<Integer>(); // 統(tǒng)計(jì)線程狀態(tài) List<Thread> threadList = new ArrayList<Thread>(); // 線程狀態(tài)碼 int threadStatusCode = 0; // 計(jì)數(shù)器 int count = 0; // 每月的日志分析 for (int m = 1; m <= 12; m++) { // 收集日期參數(shù) List<String> dateList = new ArrayList<String>(); // String date = ""; // 判斷有多少天 int days = CalendarUtil.weekForMonth(Integer.valueOf(year), m); // 組合日期 for (int i = 1; i <= days; i++) { if (i <= 9) { if (m <= 9) { date = year + "-0" + m + "-0" + i; } else { date = year + "-" + m + "-0" + i; } } else { if (m <= 9) { date = year + "-0" + m + "-" + i; } else { date = year + "-" + m + "-" + i; } } dateList.add(date); } // 啟動(dòng)線程 Thread thread = new ReadLogFileThreadByYear(dateList); thread.start(); try { // 休眠 Thread.sleep(1000L); } catch (InterruptedException e) { e.printStackTrace(); } threadList.add(thread); } // 獲取線程狀態(tài) for (Thread t : threadList) { if (t.getState().toString().equals("TERMINATED")) { threadStatusCode += 1; } } // 判斷線程是否都執(zhí)行完畢 if (threadStatusCode == 12) { // 接收參數(shù) // List<Map<String, Object>> list = ReadLogFileThread.list.subList(0, 12); List<Map<String, Object>> list = ReadLogFileThreadByYear.list; // 設(shè)置參數(shù) for (int p = 0; p < list.size(); p++) { count += (int) list.get(p).get("clickCount"); if (list.get(p).get("month").equals("01")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("02")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("03")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("04")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("05")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("06")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("07")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("08")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("09")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("10")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("11")) { yList.add((Integer) list.get(p).get("clickCount")); } else if (list.get(p).get("month").equals("12")) { yList.add((Integer) list.get(p).get("clickCount")); } } } setAttr("totalCount", count); setAttr("x", xList); setAttr("y", yList); renderJson(); }
線程方法:
package com.ninemax.util.loganalysis; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStreamReader; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import com.ninemax.util.loganalysis.tool.ConstantUtil; /** * 多線程無(wú)返回值 * * @author Darker * */ public class ReadLogFileThreadByYear extends Thread { // 日期數(shù)組 private List<String> clickDate; // 共享數(shù)據(jù) public static List<Map<String, Object>> list = new ArrayList<Map<String, Object>>(); public ReadLogFileThreadByYear(List<String> clickDate) { this.clickDate = clickDate; } /** * 讀取點(diǎn)擊日志文件 * * 例子:article.click.2016-05-20.txt * * @return */ public void run() { // 接收參數(shù) Map<String, Object> map = new HashMap<String, Object>(); // 利用FileInputStream讀取文件信息 FileInputStream fis = null; // 利用InputStreamReader進(jìn)行轉(zhuǎn)碼 InputStreamReader reader = null; // 利用BufferedReader進(jìn)行緩沖 BufferedReader bufReader = null; // 利用StringBuffer接收文件內(nèi)容容器 StringBuffer buf = new StringBuffer(); // 點(diǎn)擊量/月 int monthClick = 0; for (int i = 0; i < clickDate.size(); i++) { // 獲取文件 File clickLogFile = new File(ConstantUtil.LOGLOCATION, "article.click."+ clickDate.get(i) + ".txt"); // 判斷文件是否存在 if (!clickLogFile.exists() || clickLogFile.isDirectory()) { System.err.println(clickDate.get(i) + "的文件不存在..."); } else { try { // 節(jié)點(diǎn)流 fis = new FileInputStream(clickLogFile); // 轉(zhuǎn)換流 reader = new InputStreamReader(fis, "utf-8"); // 處理流 bufReader = new BufferedReader(reader); // 計(jì)數(shù)器 int count = 0; // 按行讀取 String line = ""; // 讀取文件 while ((line = bufReader.readLine()) != null) { count++; // 接收數(shù)據(jù) if (!line.equals(null) && !line.equals("")) { buf.append(line + "\n"); } } if (count == 0) { count = 0; } else { count = count - 1; } monthClick += count; } catch (Exception e) { e.printStackTrace(); } finally { // 關(guān)閉流 try { bufReader.close(); reader.close(); fis.close(); } catch (IOException e) { e.printStackTrace(); } } } } map.put("month", clickDate.get(0).subSequence(5, 7)); if(monthClick==0){ map.put("clickCount", 0); }else{ map.put("clickCount", monthClick); } // map.put("clickContent", buf.toString()); list.add(map); } }
相關(guān)文章
Java中字符串常見(jiàn)題之String相關(guān)講解
今天小編就為大家分享一篇關(guān)于Java中字符串常見(jiàn)題之String相關(guān)講解,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧2019-01-01Java單線程ThreadLocal串值問(wèn)題解決方案
這篇文章主要介紹了Java單線程ThreadLocal串值問(wèn)題解決方案,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04maven項(xiàng)目打包如何去掉不需要的module
文章總結(jié):在my-project工程依賴my-core和my-common,且my-project在總工程AAA中時(shí),建議通過(guò)以下兩種方案優(yōu)化打包流程:1.?使用pom區(qū)分,重新編寫(xiě)pom文件,并指定需要重新編譯的工程到modules中,然后在編譯時(shí)指定pom文件;2024-12-12Java中的synchronized和ReentrantLock的區(qū)別詳細(xì)解讀
這篇文章主要介紹了Java中的synchronized和ReentrantLock的區(qū)別詳細(xì)解讀,synchronized是Java內(nèi)建的同步機(jī)制,所以也有人稱其為 IntrinsicLocking,它提供了互斥的語(yǔ)義和可見(jiàn)性,當(dāng)一個(gè)線程已經(jīng)獲取當(dāng)前鎖時(shí),其他試圖獲取的線程只能等待或者阻塞在那里,需要的朋友可以參考下2024-01-01springboot實(shí)現(xiàn)圖片上傳與下載功能
這篇文章主要為大家詳細(xì)介紹了后端spring項(xiàng)目經(jīng)常要做的功能,實(shí)現(xiàn)圖片上傳和下載,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-12-12Java實(shí)現(xiàn)更新順序表中的指定元素的示例
本文主要介紹了Java實(shí)現(xiàn)更新順序表中的指定元素的示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06Java 多線程并發(fā)編程_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要介紹了Java 多線程并發(fā)編程的相關(guān)資料,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友可以參考下2017-05-05