zoukankan      html  css  js  c++  java
  • 线程方法

    线程方法

    ①setPriority(int newPriority)  更改线程的优先级

    ②static void sleep(long millis)  在指定的毫秒内让当前正在执行的线程休眠

    ③void.join()  等待该线程终止

    ④static void yield() 暂停当前正在执行的线程对象,并执行其他的线程

    ⑤void interrupt()    中断线程,不建议使用

    ⑥boolean isAlive()  测试线程是否处于活动状态

    停止线程

    使用一个标志位进行终止变量,当flag=false,则线程终止。

    package com.wang.thread;

    public class StopThreadDemo01 implements Runnable{
       //设置一个标志位
       private boolean flag=true;
       @Override
       public void run() {
           //线程体
           int i=0;
           while (flag){
               System.out.println("run...Thread"+i++);
          }
      }
       //设置一个公开的方法停止线程,转换标志位
       public void stop(){
           this.flag=false;
      }
       public static void main(String[] args) {
           StopThreadDemo01 stopThreadDemo01=new StopThreadDemo01();
           new Thread(stopThreadDemo01).start();

           for (int i = 0; i < 1000; i++) {
               System.out.println("main "+i);
               if (i==900){
                   //调用自己写的stop方法切换标志位,让线程停止
                   stopThreadDemo01.stop();
                   System.out.println("线程该停止了");
              }
          }
      }
    }

    线程休眠

    sleep(时间)指定当前线程阻塞的毫秒数

    sleep存在异常InterruptedException

    sleep时间达到后线程进入就绪状态

    sleep可以模拟网络延时,倒计时等

    每一个对象都有一个锁,sleep不会释放锁

    package com.wang.thread;

    //模拟网络延时 放大问题的发生性
    public class SleepThreadDemo01 implements Runnable{
       //票数
       private int ticketNumbers=10;
       @Override
       public void run() {
           while (true){
               if (ticketNumbers<=0){
                   break;
              }
               try {
                   Thread.sleep(100);//模拟延时 延迟0.1秒
              } catch (InterruptedException e) {
                   e.printStackTrace();
              }
               //Thread.currentThread().getName()当前执行线程的名字
               System.out.println(Thread.currentThread().getName()+"拿到了第"+(ticketNumbers--)+"张票");
          }
      }

       public static void main(String[] args) {
           SleepThreadDemo01 s =new SleepThreadDemo01();
           new Thread(s,"小明").start();
           new Thread(s,"老师").start();
           new Thread(s,"王迎婧").start();
      }
    }

    模拟倒计时

    package com.wang.thread;

    //模拟倒计时
    public class SleepThreadDemo02 {
       public static void main(String[] args) {
           try {
               tenDown();
          } catch (InterruptedException e) {
               e.printStackTrace();
          }
      }
       public static void tenDown() throws InterruptedException{
           int num=10;

           while (true){
                   Thread.sleep(1000);
                   System.out.println(num--);
                   if (num<=0) {
                       break;
                  }
          }
      }
    }

    每隔一秒打印系统当前时间

    package com.wang.thread;

    import java.text.SimpleDateFormat;
    import java.util.Date;

    public class SleepThreadDemo03 {
       public static void main(String[] args) {
           //打印当前系统时间
           Date startTime=new Date(System.currentTimeMillis());//获取系统当前时间
           while (true){
               try {
                   Thread.sleep(1000);//休眠一秒
                   System.out.println(new SimpleDateFormat("HH:mm:ss").format(startTime));//打印时间
                   startTime=new Date(System.currentTimeMillis());//更新当前时间

              } catch (InterruptedException e) {
                   e.printStackTrace();
              }
          }
      }
    }

    线程礼让

    礼让线程 ,让当前正在执行的线程暂停,但不阻塞

    将线程从运行状态转为就绪状态

    让cpu重新调度,礼让不一定成功,看cpu心情。

    package com.wang.thread;

    //测试礼让线程
    //礼让不一定成功
    public class YieldDemo01 {
       public static void main(String[] args) {
           MyYield myYield=new MyYield();
           new Thread(myYield,"wang").start();
           new Thread(myYield,"yi").start();
      }
    }
    class MyYield implements Runnable{

       @Override
       public void run() {
           System.out.println(Thread.currentThread().getName()+"线程开始执行");
           Thread.yield();//礼让
           System.out.println(Thread.currentThread().getName()+"线程停止执行");
      }
    }

    Join

    Join合并线程,待此线程执行完成后,再执行其他线程,其他线程阻塞

    可以想象成插队

    package com.wang.thread;

    //测试Join方法,想象成插队
    public class JoinDemo01 implements Runnable{
       @Override
       public void run() {
           for (int i = 0; i < 100; i++) {
               System.out.println("线程vip来了 "+i);
          }
      }

       public static void main(String[] args) throws InterruptedException {
           //启动线程
           JoinDemo01 joinDemo01=new JoinDemo01();
           Thread thread=new Thread(joinDemo01);
           thread.start();

           //主线程
           for (int i = 0; i < 1000; i++) {
               if (i==200){
                   thread.join();//插队
              }
               System.out.println("main "+i);
          }
      }
    }

    观测线程状态

    package com.wang.thread;

    //观察测试线程的状态
    public class StateDemo01 {
       public static void main(String[] args) throws InterruptedException {
           Thread thread=new Thread(()->{
               for (int i = 0; i < 5; i++) {
                   try {
                       Thread.sleep(1000);
                  } catch (InterruptedException e) {
                       e.printStackTrace();
                  }
              }
               System.out.println("//////");
          });
           //观察状态
           Thread.State state = thread.getState();
           System.out.println(state);//NEW
           //观察启动后
           thread.start();//启动线程
           state = thread.getState();
           System.out.println(state);//Run

           while (state!=Thread.State.TERMINATED){//判断只要线程不终止,就一直输出状态
               Thread.sleep(100);
               state=thread.getState();//更新线程状态
               System.out.println(state);//输出状态
          }
      }
    }

    线程优先级

    Java提供一个线程调度器来监控程序中启动后进入就绪状态的所有线程,线程调度器按照优先级决定应该调度哪个线程来执行。

    线程的优先级用数字表示,范围从1-10

    Thread.MIN_PRIORITY=1;

    Thread.MAX_PRIORITY=10;

    Thread.NORM_PRIORITY=5;

    优先级越高,权重越大,先执行的几率大。

    使用以下方式改变或获取优先级

    getPriority().setPriority(int xxx)

    package com.wang.thread;

    //测试线程的优先级
    public class PriorityDemo01 {
       public static void main(String[] args) {
           //主线程默认优先级
           System.out.println(Thread.currentThread().getName()+"-->"+Thread.currentThread().getPriority());

           MyPriority priority=new MyPriority();
           Thread thread1=new Thread(priority);
           Thread thread2=new Thread(priority);
           Thread thread3=new Thread(priority);
           Thread thread4=new Thread(priority);
           Thread thread5=new Thread(priority);
           Thread thread6=new Thread(priority);

           //先设置优先级,再启动
           thread1.start();//优先级默认是5

           thread2.setPriority(1);
           thread2.start();

           thread3.setPriority(4);
           thread3.start();

           thread4.setPriority(Thread.MAX_PRIORITY);
           thread4.start();

           thread5.setPriority(8);
           thread5.start();

           thread6.setPriority(7);
           thread6.start();
      }
    }
    class MyPriority implements Runnable{

       @Override
       public void run() {
           System.out.println(Thread.currentThread().getName()+"-->"+Thread.currentThread().getPriority());
      }
    }

    守护(daemon)线程

    线程分为用户线程守护线程

    虚拟机必须确保用户线程执行完毕  用户线程main

    虚拟机不用等待守护线程执行完毕   gc线程不用等待虚拟机

    package com.wang.thread;

    //测试守护线程
    public class DaemonDemo01 {
       public static void main(String[] args) {
        God god=new God();
        You1 you1=new You1();

        Thread thread=new Thread(god);
        thread.setDaemon(true);//默认是false表示是用户线程,正常的线程都是用户线程

           thread.start();//守护线程启动
           new Thread(you1).start();
      }
    }
    //守护线程
    class God implements Runnable{

       @Override
       public void run() {
           while (true){
               System.out.println("protect you");
          }
      }
    }
    //用户线程
    class You1 implements Runnable{

       @Override
       public void run() {
           for (int i = 0; i < 36500; i++) {
               System.out.println("happy "+i);
          }
           System.out.println("bye world");
      }
    }

     

  • 相关阅读:
    Mysql-学习笔记(==》事件 十二)
    Mysql-学习笔记(==》触发器 十一)
    Mysql-学习笔记(==》函数的建立与使用 十)
    Mysql-学习笔记(==》存储过程 九)
    Mysql-学习笔记(==》常用函数 八)
    Mysql-学习笔记(==》增删主键建立索引 七)
    Mysql-学习笔记(==》约束 六)
    Mysql-学习笔记(==》集合函数与分组四)
    Mysql-学习笔记(==》连接查询_高级查询五)
    Unity3D优化技巧系列七
  • 原文地址:https://www.cnblogs.com/wyj96/p/11979724.html
Copyright © 2011-2022 走看看