服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|

服务器之家 - 编程语言 - JAVA教程 - Java多线程继承Thread类详解

Java多线程继承Thread类详解

2020-05-18 12:31java教程网 JAVA教程

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

调用方法:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
/**
 * 点击量/月(年)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();
 }

线程方法:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
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);
 
 }
 
}

 

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
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类的方式来创建线程。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
/*
* 示例:创建三个线程,每过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();
  }
}

 

延伸 · 阅读

精彩推荐