多线程(一) 创建多线程+线程常用方法

理解Runnable和Thread的区别:https://blog.csdn.net/zhaojianting/article/details/9766437


多线程即在同一时间,可以做多件事情。
创建多线程有3种方式,分别是继承线程类,实现Runnable接口,匿名类


  • 启动一个线程

线程有三种创建方法:
1.继承Thread类的方式
    public class Testthread extends Thread{
        public void run(){
            //
        }
    }

run方法里面就是写你这个线程要做的事情。

然后:

    TestThread t1=new TestThread();
    t1.start();

通过.start()方法就可以开始t1这个线程啦!

 
2.实现Runnable的方式

    public class ttt implements Runnable{
         
        public void run(){
            
        }
    }

然后:

    ttt t2 = new ttt();
             
    new Thread(t2).start();

就可以开始t2这个线程啦,需要注意的同样也是要有.start()才能运行这个线程。


3.匿名类的方式
这也是我喜欢的方式,因为写起来方便

    Thread t3 = new Thread() {
        public void run()
        {
            //
        }
    };
同样的要注意:启动线程是start()方法,run()并不能启动一个新的线程。

 1 package UML;
 2 /*
 3  *多线程即在同一时间,可以做多件事情。
 4  *创建多线程有3种方式,分别是继承线程类,实现Runnable接口,匿名类
 5  *线程的概念:首先要理解进程(Processor)和线程(Thread)的区别
 6                 进程:启动一个LOL.exe就叫一个进程。 接着又启动一个DOTA.exe,这叫两个进程。
 7                 线程:线程是在进程内部同时做的事情,比如在LOL里,有很多事情要同时做,比如"盖伦” 击杀“提莫”,同时“赏金猎人”又在击杀“盲僧”,这就是由多线程来实现的。
 8 */
 9 public class TestThread {
10 
11     public static void main(String[] args) {
12         
13         Hero gareen = new Hero();
14         gareen.name = "盖伦";
15         gareen.hp = 616;
16         gareen.damage = 50;
17  
18         Hero teemo = new Hero();
19         teemo.name = "提莫";
20         teemo.hp = 300;
21         teemo.damage = 30;
22          
23         Hero bh = new Hero();
24         bh.name = "赏金猎人";
25         bh.hp = 500;
26         bh.damage = 65;
27          
28         Hero leesin = new Hero();
29         leesin.name = "盲僧";
30         leesin.hp = 455;
31         leesin.damage = 80;
32         
33         //方法1 创建多线程-继承线程类 
34         /*使用多线程,就可以做到盖伦在攻击提莫的同时,赏金猎人也在攻击盲僧设计一个类KillThread 继承Thread,并且重写run方法启动线程办法: 实例化一个KillThread对象,并且调用其start方法就可以观察到 赏金猎人攻击盲僧的同时,盖伦也在攻击提莫 
35         KillThread killThread1=new KillThread(gareen,teemo);
36         killThread1.start();
37         KillThread killThread2 = new KillThread(bh,leesin);
38         killThread2.start();*/
39         
40          //方法2 创建多线程-实现Runnable接口 
41         /*创建类Battle,实现Runnable接口。启动的时候,首先创建一个Battle对象,然后再根据该battle对象创建一个线程对象,并启动
42         Battle b1=new Battle(gareen,teemo);//b1 对象实现了Runnable接口,所以有run方法,但是直接调用run方法,并不会启动一个新的线程。
43         new Thread(b1).start();//必须借助一个线程对象的start()方法,才会启动一个新的线程,这个线程启动的时候,就会去执行b1.run()方法
44         Battle b2=new Battle(bh,leesin);
45         new Thread(b2).start();*/
46         
47         /*方法3 创建多线程-匿名类 
48          *  使用匿名类,继承Thread,重写run方法,直接在run方法中写业务代码
49          *  匿名类的一个好处是可以很方便的访问外部的局部变量。
50          *  前提是外部的局部变量需要被声明为final。(JDK7以后就不需要了) */
51         Thread t1=new Thread() {
52             public void run() {
53                 while(!teemo.isDead()) {
54                     gareen.attackHero(teemo);
55                 }
56             }
57         };
58         t1.start();
59    
60         Thread t2=new Thread() {
61             public void run() {
62                 while(!teemo.isDead()) {
63                     bh.attackHero(leesin);
64                 }
65             }
66         };
67         t2.start();
68     }
69 }
TestThread.java
 1 package UML;
 2 
 3 public class KillThread extends Thread {
 4     private Hero h1;
 5     private Hero h2;
 6  
 7     public KillThread(Hero h1, Hero h2){
 8         this.h1 = h1;
 9         this.h2 = h2;
10     }
11  
12     public void run(){
13         while(!h2.isDead()){
14             h1.attackHero(h2);
15         }
16     }
17 }
KillThread.java
 1 package UML;
 2 
 3 public class Battle implements Runnable {
 4     
 5     private Hero h1;
 6     private Hero h2;
 7     public Battle(Hero h1,Hero h2) {
 8         this.h1=h1;
 9         this.h2=h2;
10     }
11     @Override
12     public void run() {
13         // TODO Auto-generated method stub
14         while(!h2.isDead()) {
15             h1.attackHero(h2);
16         }
17 
18     }
19 
20 }
Battle.java
 1 package UML;
 2 import java.util.*;
 3 public class Hero implements Comparable<Hero>{
 4     public String name;
 5     public float hp;
 6     public int damage;
 7     public Hero() {
 8     }
 9     // 增加一个初始化name的构造方法
10     public Hero(String name) {
11  
12         this.name = name;
13     }
14     // 重写toString方法
15     public String toString() {
16         //return String.format("[name:%s hp:%.0f damage:%.0f]%n", name,hp,damage);
17         return "Hero [name=" + name + ", hp=" + hp + ", damage=" + damage + "]
";
18     }
19     public Hero(String name,int hp,int damage) {
20         this.name=name;
21         this.hp=hp;
22         this.damage=damage;
23     }
24     @Override
25     public int compareTo(Hero anotherHero) {
26         if(damage<anotherHero.damage)
27             return 1; 
28         else
29             return -1;
30     }
31     public void attackHero(Hero h) {
32         try {
33             Thread.sleep(1000);
34         }catch (InterruptedException e) {
35             // TODO Auto-generated catch block
36             e.printStackTrace();
37         }
38         h.hp-=damage;
39         System.out.format("%s is attacking %s,%s'blood now is %.0f%n",name,h.name,h.name,h.hp);
40         if(h.isDead())
41             System.out.println(h.name +"死了!");
42     }
43     public boolean isDead() {
44         return 0>=hp?true:false;
45     }
46 }
Hero.java

  • 线程常用方法

1、暂停当前线程: .sleep()
顾名思义,把当前的线程暂停一定时间,其他的线程并不会受到影响。
注意是会抛出interruptedException异常的。


2、加入到当前线程中: .join()
join的作用是当这个线程运行完事儿之后程序才继续往下走,不然会一直停在join方法处。
            使用场景:如果在某处后边的处理需要使用到t1的数据,那么可以用join来等待t1线程执行结束。


3、定义线程的优先级: .setPriority()
当线程处于竞争关系的时候,优先级高的线程会获得更多的cup资源,也就是这个线程会执行得更快


4、临时暂停: .yield
并不是直接就给它停住了,而是它自己也在慢慢运行,但是会把更多的cup资源让给其他的线程。


5、守护线程: .setDaemon(true)
守护线程的概念是: 当一个进程里,所有的线程都是守护线程的时候,结束当前进程。
就是说可以用来把一些辅助线程写成守护的,那么当干实事的线程完事了,这些守护的线程就没必要继续了。
比如写日志啊,性能统计等。

  1 package UML;
  2 
  3 import java.util.*;
  4 
  5 public class TestThread1 {
  6     /*当前线程暂停
  7       Thread.sleep(1000); 表示当前线程暂停1000毫秒 ,其他线程不受影响
  8       Thread.sleep(1000); 会抛出InterruptedException 中断异常,因为当前线程sleep的时候,
  9         有可能被停止,这时就会抛出 InterruptedException */
 10     public static void example1() {
 11         Thread t1=new Thread() {
 12             public void run() {
 13                 int seconds=0;
 14                 while(true) {
 15                     try {
 16                         Thread.sleep(1000);
 17                     }catch(InterruptedException e) {
 18                         e.printStackTrace();
 19                     }
 20                     System.out.printf("已经玩了LOL %d 秒%n", seconds++);
 21                 }
 22             }
 23         };
 24         t1.start();
 25     }
 26     
 27     /*所有进程,至少会有一个线程即主线程,即main方法开始执行,就会有一个看不见的主线程存在。
 28         在42行执行t.join,即表明在主线程中加入该线程。
 29         主线程会等待该线程结束完毕, 才会往下运行。 */
 30     public static void example2() {
 31         final Hero gareen = new Hero();
 32         gareen.name = "盖伦";
 33         gareen.hp = 616;
 34         gareen.damage = 50;
 35   
 36         final Hero teemo = new Hero();
 37         teemo.name = "提莫";
 38         teemo.hp = 300;
 39         teemo.damage = 30;
 40           
 41         final Hero bh = new Hero();
 42         bh.name = "赏金猎人";
 43         bh.hp = 500;
 44         bh.damage = 65;
 45           
 46         final Hero leesin = new Hero();
 47         leesin.name = "盲僧";
 48         leesin.hp = 455;
 49         leesin.damage = 80;
 50           
 51         Thread t1= new Thread(){
 52             public void run(){
 53                 while(!teemo.isDead()){
 54                     gareen.attackHero(teemo);
 55                 }              
 56             }
 57         };
 58           
 59         t1.start();
 60         //代码执行到这里,一直是main线程在运行
 61         try {
 62             //t1线程加入到main线程中来,只有t1线程运行结束,才会继续往下走
 63             t1.join();
 64         } catch (InterruptedException e) {
 65             // TODO Auto-generated catch block
 66             e.printStackTrace();
 67         }
 68  
 69         Thread t2= new Thread(){
 70             public void run(){
 71                 while(!leesin.isDead()){
 72                     bh.attackHero(leesin);
 73                 }              
 74             }
 75         };
 76         //会观察到盖伦把提莫杀掉后,才运行t2线程
 77         t2.start();
 78     }
 79     
 80     /* 线程优先级 
 81      * 当线程处于竞争关系的时候,优先级高的线程会有更大的几率获得CPU资源
 82            为了演示该效果,要把暂停时间去掉,多条线程各自会尽力去占有CPU资源
 83        同时把英雄的血量增加100倍,攻击减低到1,才有足够的时间观察到优先级的演示
 84        如图可见,线程1的优先级是MAX_PRIORITY,所以它争取到了更多的CPU资源执行代码 
 85      */
 86     public static void example3() {
 87         final Hero gareen = new Hero();
 88         gareen.name = "盖伦";
 89         gareen.hp = 6160;
 90         gareen.damage = 1;
 91   
 92         final Hero teemo = new Hero();
 93         teemo.name = "提莫";
 94         teemo.hp = 3000;
 95         teemo.damage = 1;
 96           
 97         final Hero bh = new Hero();
 98         bh.name = "赏金猎人";
 99         bh.hp = 5000;
100         bh.damage = 1;
101           
102         final Hero leesin = new Hero();
103         leesin.name = "盲僧";
104         leesin.hp = 4505;
105         leesin.damage = 1;
106           
107         Thread t1= new Thread(){
108             public void run(){
109  
110                 while(!teemo.isDead()){
111                     gareen.attackHero(teemo);
112                 }              
113             }
114         };
115           
116         Thread t2= new Thread(){
117             public void run(){
118                 while(!leesin.isDead()){
119                     bh.attackHero(leesin);
120                 }              
121             }
122         };
123          
124         t1.setPriority(Thread.MAX_PRIORITY);
125         t2.setPriority(Thread.MIN_PRIORITY);
126         t1.start();
127         t2.start();
128     }
129     /*临时暂停
130      * 当前线程,临时暂停,使得其他线程可以有更多的机会占用CPU资源 
131      */
132     public static void example4() {
133         final Hero gareen = new Hero();
134         gareen.name = "盖伦";
135         gareen.hp = 61600;
136         gareen.damage = 1;
137   
138         final Hero teemo = new Hero();
139         teemo.name = "提莫";
140         teemo.hp = 30000;
141         teemo.damage = 1;
142           
143         final Hero bh = new Hero();
144         bh.name = "赏金猎人";
145         bh.hp = 50000;
146         bh.damage = 1;
147           
148         final Hero leesin = new Hero();
149         leesin.name = "盲僧";
150         leesin.hp = 45050;
151         leesin.damage = 1;
152           
153         Thread t1= new Thread(){
154             public void run(){
155  
156                 while(!teemo.isDead()){
157                     gareen.attackHero(teemo);
158                 }              
159             }
160         };
161           
162         Thread t2= new Thread(){
163             public void run(){
164                 while(!leesin.isDead()){
165                     //临时暂停,使得t1可以占用CPU资源
166                     Thread.yield();
167                      
168                     bh.attackHero(leesin);
169                 }              
170             }
171         };
172          
173         t1.setPriority(5);
174         t2.setPriority(5);
175         t1.start();
176         t2.start();
177     }
178     /* 守护线程 
179      * 守护线程的概念是: 当一个进程里,所有的线程都是守护线程的时候,结束当前进程。
180       就好像一个公司有销售部,生产部这些和业务挂钩的部门。
181     除此之外,还有后勤,行政等这些支持部门。
182     如果一家公司销售部,生产部都解散了,那么只剩下后勤和行政,那么这家公司也可以解散了。
183     守护线程就相当于那些支持部门,如果一个进程只剩下守护线程,那么进程就会自动结束。
184     守护线程通常会被用来做日志,性能统计等工作。 
185      */
186     public static void example5() {
187         Thread t1= new Thread(){
188             public void run(){
189                 int seconds =0;
190                  
191                 while(true){
192                     try {
193                         Thread.sleep(1000);
194                     } catch (InterruptedException e) {
195                         // TODO Auto-generated catch block
196                         e.printStackTrace();
197                     }
198                     System.out.printf("已经玩了LOL %d 秒%n", seconds++);
199                      
200                 }              
201             }
202         };
203         t1.setDaemon(true);
204         t1.start();
205     }
206     /* 练习-英雄充能 
207      * 英雄有可以放一个技能叫做: 波动拳-a du gen。
208 每隔一秒钟,可以发一次,但是只能连续发3次。
209 发完3次之后,需要充能5秒钟,充满,再继续发。
210 借助本章节学习到的知识点,实现这个效果 
211      */
212     public static void example6() {
213         Thread t1 = new Thread() {
214             public void run() {
215  
216                     for(int i = 0;i < 5;i ++)
217                     {
218                         for(int j = 0;j < 3;j ++) {
219                             System.out.println("正在发送第"+(j+1)+"波动拳");
220                             try {
221                                 Thread.sleep(1000);
222                             }catch(InterruptedException e ) {
223                                 e.printStackTrace();
224                             }
225                         }
226                         System.out.println("开始为时5s的充能");
227                         try {
228                             Thread.sleep(5000);
229                         }catch(InterruptedException e ) {
230                             e.printStackTrace();
231                         }
232                     }
233                 }
234             
235         };
236         t1.start();
237     }
238     /*练习-破解密码
239      * 1. 生成一个长度是3的随机字符串,把这个字符串当作 密码
240        2. 创建一个破解线程,使用穷举法,匹配这个密码
241        3. 创建一个日志线程,打印都用过哪些字符串去匹配,这个日志线程设计为守护线程
242 提示: 破解线程把穷举法生成的可能密码放在一个容器中,日志线程不断的从这个容器中拿出可能密码,并打印出来。 如果发现容器是空的,就休息1秒,如果发现不是空的,就不停的取出,并打印。
243 
244      */
245     public static void example7() {
246         //提示:破解线程把穷举法生成的可能密码放在一个容器中,日志线程不断的从这个容器中拿出可能密码,并打印出来。 如果发现容器是空的,就休息1秒,如果发现不是空的,就不停的取出,并打印。
247         List<String> passwords = new ArrayList<String>();//容器记录产生的可能密码
248         //1.生成随机字符串pwd
249         String s="0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
250         char cs[]=new char[3];
251         for(int i=0;i<cs.length;i++) {
252             int index=(int)(Math.random()*s.length());
253             cs[i]=s.charAt(index);
254         }
255         String pwd = new String(cs);
256         System.out.println("设置的密码为:"+pwd);
257         //2.创建一个破解线程,使用穷举法,匹配这个密码
258         Thread t1 = new Thread() {
259             public void run() {
260                 for(char i='0';i<='z';i++) {
261                     if(Character.isDigit(i)||Character.isAlphabetic(i)) {
262                         for(char j='0';j<='z';j++) {
263                             if(Character.isDigit(j)||Character.isAlphabetic(j)) {
264                                 for(char k='0';k<='z';k++) {
265                                     if(Character.isDigit(k)||Character.isAlphabetic(k)) {
266                                         StringBuffer buf=new StringBuffer();
267                                         buf.append(i);
268                                         buf.append(j);
269                                         buf.append(k);
270                                         passwords.add(buf.toString());
271                                         System.out.println("产生的新密码是:"+buf.toString());
272                                         if(buf.toString().equals(pwd)) {
273                                             System.out.println("找到了,密码是" + buf+"即将退出破解线程");
274                                             return;
275                                         }else {
276                                             System.out.println("...");
277                                         }
278                                     }
279                                 }
280                             }
281                         }
282                     }
283                 }
284             }
285         };
286         t1.start();
287         //3.创建一个日志线程,打印都用过哪些字符串去匹配,这个日志线程设计为守护线程
288         Thread t2= new Thread() {
289             public void run() {
290                 while(true) {
291                     if(passwords.isEmpty()) {
292                         try {
293                             Thread.sleep(1000);
294                         }catch(InterruptedException e) {
295                             e.printStackTrace();
296                         }
297                     }
298                     System.out.println("最新穷举的密码:"+passwords.get(passwords.size()-1));
299                 }
300                 
301             }
302         };
303         t2.setDaemon(true);
304         t2.start();
305     }
306     public static void main(String[] args) {
307         //example1();//当前线程暂停 
308         //example2();//在主线程中加入线程
309         //example3();//线程优先级 
310         //example4();//临时暂停 
311         //example5();//守护进程
312         
313         
314         //example6();//作业1-波动拳
315         example7();//作业2-破解密码
316         
317     }
318 }
Threadtest2.java
原文地址:https://www.cnblogs.com/xuechengmeigui/p/13151376.html