zoukankan      html  css  js  c++  java
  • 多线程(一) 创建多线程+线程常用方法

    理解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
  • 相关阅读:
    c#之添加window服务(定时任务)
    dotnet core 之 CORS使用示例
    CORS讲解
    vim的多文件编辑和多窗口功能
    vim操作常用命令总结
    vmware的三种网络模式讲解
    vmware下的linux没有网络问题解决思路
    asp.net core 系列之允许跨域访问2之测试跨域(Enable Cross-Origin Requests:CORS)
    asp.net core 系列之允许跨域访问-1(Enable Cross-Origin Requests:CORS)
    asp.net core 系列之允许跨域访问(Enable Cross-Origin Requests:CORS)
  • 原文地址:https://www.cnblogs.com/xuechengmeigui/p/13151376.html
Copyright © 2011-2022 走看看