1. 首页
  2. 编程与技术

Java多线程继承Thread类详解

发布于 2016-08-07 20:45:06 | 54 次阅读 | 评论: 0 | 来源: 网友投递

这里有新鲜出炉的Java设计模式，程序狗速度看过来！

Java程序设计语言

java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言，是由Sun Microsystems公司于1995年5月推出的Java程序设计语言和Java平台（即JavaEE(j2ee), JavaME(j2me), JavaSE(j2se)）的总称。

Java多线程的两种实现方式：继承Thread类 & 实现Runable接口，今天我们来学习下继承Thread类，希望大家能够喜欢

调用方法:


/**
 * 点击量/月(年)Thread
 */
 public void yearlyClickThread() {
 // 获取参数
 String year = getPara("year");
 // 统计数据集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");
 // 统计数据集Y
 List<Integer> yList = new ArrayList<Integer>();
 // 统计线程状态
 List<Thread> threadList = new ArrayList<Thread>();
 // 线程状态码
 int threadStatusCode = 0;
 // 计数器
 int count = 0;
 // 每月的日志分析
 for (int m = 1; m <= 12; m++) {
  // 收集日期参数
  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);
  }
  // 启动线程
  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) {
  // 接收参数
  // List<Map<String, Object>> list = ReadLogFileThread.list.subList(0, 12);
  List<Map<String, 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 List<String> clickDate;
 // 共享数据
 public static List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
 
 public ReadLogFileThreadByYear(List<String> clickDate) {
 this.clickDate = clickDate;
 }

 /**
 * 读取点击日志文件
 * 
 * 例子:article.click.2016-05-20.txt
 * 
 * @return
 */
 public void run() {
 // 接收参数
 Map<String, Object> map = new HashMap<String, 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);

 }
 
}

同样给大家分享下网友的实例


package JavaThread;
class firstThread extends Thread
{
  private String name = null;
  public firstThread(String str)
  {
    this.name = str;
  }
  public void run()
  {
    for(int i=1;i<=3;i++)
    {
      System.out.println("线程"+this.name+"第"+i +"执行");
      try {
        Thread.sleep(50);
      } catch (InterruptedException e) {
        
        e.printStackTrace();
      }
    }
  }
}

class secondThread extends Thread
{
  private String name = null;
  public secondThread(String s)
  {
    this.name = s;
  }
  public void run()
  {
    for(int i=1;i<=3;i++)
    {
      System.out.println("线程"+this.name+"第"+i +"执行");
      try {
        Thread.sleep(50);
        Thread.yield();
      } catch (InterruptedException e) {
  
        e.printStackTrace();
      }
    }
  }
}
public class TestThread
{
  public static void main(String[] args)
  {
    firstThread p = new firstThread("first");
    secondThread pth = new secondThread("second");
    p.setPriority(4);
    pth.setPriority(9);
    p.start();
    pth.start();
  }

}

简单讲下继承Thread类

                步骤：
                a，定义类继承Thread类。
                b，覆盖Thread类中的run方法，将需要被多线程执行的代码定义到该run方法当中。
                c，建立Thread类的子类创建线程对象。
                d，调用start方法，开启线程并调用该线程的run方法。

        下面有个示例来让你直观的了解怎么用继承Thread类的方式来创建线程。


    /*
    * 示例：创建三个线程，每过2秒打印一下线程的名称，打印三次
    */
    public class Thread1 extends Thread{
        private final int MAX = 3;//最大打印次数
        private int COUNT = 1;//计数
        private final int TIME = 2;//间隔时间
    
        //接收线程名称
        public Thread1(String name) {
            super(name);
        }
        //覆盖run方法，在里面写我们要执行的代码
        public void run() {
            while(COUNT<= MAX){
                System.out.println(this.getName());
                COUNT++;
                //每次打印后，在一段时间后再打印
                try {
                    Thread.sleep(TIME*1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        public static void main(String[] args) {
            Thread1 t1 = new Thread1("线程1");//创建线程
            Thread1 t2 = new Thread1("线程2");
            Thread1 t3 = new Thread1("线程3");
            t1.start(); //开启线程
            t2.start();
            t3.start();
            //也可以使用下面这种方式书写
            //new Thread1("线程4").start();
        }
    }



相关阅读 :
Java多线程继承Thread类详解
基于Java回顾之多线程同步的使用详解
java多线程编程之使用thread类创建线程
详解Java多线程编程中LockSupport类的线程阻塞用法
Java多线程编程中使用Condition类操作锁的方法详解
详解Java多线程编程中互斥锁ReentrantLock类的用法
Java多线程编程中ThreadLocal类的用法及深入
java多线程编程之Synchronized关键字详解
详解Java多线程编程中的线程同步方法
java多线程Future和Callable类示例分享
Java 多线程synchronized关键字详解(六)
java多线程下载实例详解
最新网友评论  共有(0)条评论 发布评论 返回顶部
推荐阅读
  • 终极炫富——2016 年 iOS 开发者收入调查报告
  • 年度大片：Stack Overflow 2017 开发者调查报告发布！
  • 开发者需要大学学位吗？
  • 程序员多大年纪算高龄，届时该何去何从？
  • 2017 年高薪编程语言排行榜，你的语言上榜没？
  • 各编程语言开发者最常使用的按键，中了没?
  • 伤不起的三十岁，干不动的程序员要何去何从？
  • 2016年中国加班最狠IT公司排行
  • 一句话"面试"漫画：黑了苹果、谷歌、三星
  • 拿代码量算 KPI ……跟程序员们来这套？
  • 程序员遇到 Bug 时的 30 个反应，你是哪一种？
  • 2016年收入最高的5个编程语言 Java和C没在前五?
  • 为什么很少见人傻钱多的程序员炫富？
  • 阿里月薪两万是什么体验？
  • 代码缩进时 程序员更喜欢空格键还是Tab键？
    • 最新资讯
  • Oracle数据库表中字段顺序的修改方法
  • ASP.NET MVC 4使用PagedList.Mvc分页的实现代码
  • Oracle实例启动时报错：ORA-32004的解决方法
  • 解读ASP.NET 5 & MVC6系列教程（7）：依赖注入
  • 详解IDEA用maven创建springMVC项目和配置
  • ASP.NET MVC5网站开发之展示层架构（五）
  • SpringBoot创建maven多模块项目实战代码
  • 详解SpringBoot缓存的实例代码(EhCache 2.x 篇)
  • ASP.NET MVC下拉框联动实例解析
  • 详解SpringBoot之集成Spring AOP
  • 编辑器Ueditor和SpringBoot 的整合方法
  • ASP.NET的广告控件AdRotator用法分析
  • js将当前时间格式化为 年-月-日 时:分:秒的实现代码
  • springboot + swagger 实例代码
  • ASP.NET MVC5网站开发之用户资料的修改和删除3（七）
    • 后端技术
    前端技术
    数据库
    热门框架
    常用IDE
    其他
    Copyright © 2007-2017 PHPERZ.COM All Rights Reserved   冀ICP备14009818号  版权声明  广告服务