软件开发|编程技术|编程代码|编程入门先学什么—程序设计语言

Java多线程继承Thread类详解第1/2页

调用方法:

/** * 点击量/月(年)Thread */ public void yearlyClickThread() { // 获取参数 String year = getPara("year"); // 统计数据集X ListString xList = new ArrayListString(); 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"); // 统计数据集Y ListInteger yList = new ArrayListInteger(); // 统计线程状态 ListThread threadList = new ArrayListThread(); // 线程状态码 int threadStatusCode = 0; // 计数器 int count = 0; // 每月的日志分析 for (int m = 1; m = 12; m++) { // 收集日期参数 ListString dateList = new ArrayListString(); // 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); } // 启动线程 Thread thread = new ReadLogFileThreadByYear(dateList); thread.start(); try { // 休眠 Thread.sleep(1000L); } catch (InterruptedException e) { e.printStackTrace(); } threadList.add(thread); } // 获取线程状态 for (Thread t : threadList) { if (t.getState().toString().equals("TERMINATED")) { threadStatusCode += 1; } } // 判断线程是否都执行完毕 if (threadStatusCode == 12) { // 接收参数 // ListMapString, Object list = ReadLogFileThread.list.subList(0, 12); ListMapString, Object list = ReadLogFileThreadByYear.list; // 设置参数 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;/** * 多线程无返回值 *  * @author Darker * */public class ReadLogFileThreadByYear extends Thread { // 日期数组 private ListString clickDate; // 共享数据 public static ListMapString, Object list = new ArrayListMapString, Object();  public ReadLogFileThreadByYear(ListString clickDate) { this.clickDate = clickDate; } /** * 读取点击日志文件 *  * 例子:article.click.2016-05-20.txt *  * @return */ public void run() { // 接收参数 MapString, Object map = new HashMapString, Object(); // 利用FileInputStream读取文件信息 FileInputStream fis = null; // 利用InputStreamReader进行转码 InputStreamReader reader = null; // 利用BufferedReader进行缓冲 BufferedReader bufReader = null; // 利用StringBuffer接收文件内容容器 StringBuffer buf = new StringBuffer(); // 点击量/月 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 {  // 节点流  fis = new FileInputStream(clickLogFile);  // 转换流  reader = new InputStreamReader(fis, "utf-8");  // 处理流  bufReader = new BufferedReader(reader);  // 计数器  int count = 0;  // 按行读取  String line = "";  // 读取文件  while ((line = bufReader.readLine()) != null) {  count++;  // 接收数据  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 {  // 关闭流  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); } }
12下一页阅读全文