Day09

多线程

Java.Thread

 

进程和线程关系及区别

1.定义

进程是具有一定独立功能的程序关于某个数据集合上的一次运行活动,进程是系统进行资源分配和调度的一个独立单位.

线程是进程的一个实体,是CPU调度和分派的基本单位,它是比进程更小的能独立运行的基本单位.线程自己基本上不拥有系统资源,只拥有一点在运行中必不可少的资源(如程序计数器,一组寄存器和栈),但是它可与同属一个进程的其他的线程共享进程所拥有的全部资源.

2.关系 一个线程可以创建和撤销另一个线程;同一个进程中的多个线程之间可以并发执行.

相对进程而言,线程是一个更加接近于执行体的概念,它可以与同进程中的其他线程共享数据,但拥有自己的栈空间,拥有独立的执行序列。

3.区别 进程和线程的主要差别在于它们是不同的操作系统资源管理方式。进程有独立的地址空间,一个进程崩溃后,在保护模式下不会对其它进程产生影响,而线程只是一个进程中的不同执行路径。线程有自己的堆栈和局部变量,但线程之间没有单独的地址空间,一个线程死掉就等于整个进程死掉,所以多进程的程序要比多线程的程序健壮,但在进程切换时,耗费资源较大,效率要差一些。但对于一些要求同时进行并且又要共享某些变量的并发操作,只能用线程,不能用进程。

根本区别:进程是操作系统资源分配的基本单位,而线程是任务调度和执行的基本单位

1) 简而言之,一个程序至少有一个进程,一个进程至少有一个线程.

2) 线程的划分尺度小于进程,使得多线程程序的并发性高。

3) 另外,进程在执行过程中拥有独立的内存单元,而多个线程共享内存,从而极大地提高了程序的运行效率。

4) 线程在执行过程中与进程还是有区别的。每个独立的线程有一个程序运行的入口、顺序执行序列和程序的出口。但是线程不能够独立执行,必须依存在应用程序中,由应用程序提供多个线程执行控制。

5) 从逻辑角度来看,多线程的意义在于一个应用程序中,有多个执行部分可以同时执行。但操作系统并没有将多个线程看做多个独立的应用,来实现进程的调度和管理以及资源分配。这就是进程和线程的重要区别。

4.优缺点 线程和进程在使用上各有优缺点:线程执行开销小,但不利于资源的管理和保护;而进程正相反。同时,线程适合于在SMP机器上运行,而进程则可以跨机器迁移。

线程创建

Thread class

  1. 自定义线程类继承Thread

  2. 重写 run() 方法,编写线程执行体

  3. 创建线程对象,调用 start() 方法启动线程

package demo01;

public class TestThread extends Thread{
   @Override
   public void run() {
       //run方法线程体
       for (int i = 0; i < 200; i++) {
           System.out.println("git"+i);
      }
  }

   public static void main(String[] args) {
       //main线程,主线程
TestThread testThread1 = new TestThread();
       //调用start()方法开启线程
       testThread1.start();

       for (int i = 0; i < 1000; i++) {
           System.out.println("study"+i);
      }
  }
}

 

网络图片下载练习

package demo01;

import org.apache.commons.io.FileUtils;
import java.io.File;
import java.io.IOException;
import java.net.URL;

public class TestThread02 extends Thread{

   private String url;
   private String name;
   public TestThread02(String url,String name){
       this.name=name;
       this.url=url;
  }
   //下载图片线程的执行体
   @Override
   public void run() {
       WebDownloader webDownloader =new WebDownloader();
       webDownloader.downloader(url,name);
       System.out.println("下载的文件名:"+name);
  }
   public static void main(String[] args) {
       //创建线程对象
       TestThread02 t1 = new TestThread02("https://static.nike.com/a/images/c_limit,w_592,f_auto/t_product_v1/044c17f1-6131-4352-9dc8-f1ccef6b8ace/af1-1-%E7%94%B7%E5%AD%90%E8%BF%90%E5%8A%A8%E9%9E%8B-fM9NKw.jpg","1.jpg");
       TestThread02 t2 = new TestThread02("https://static.nike.com/a/images/c_limit,w_592,f_auto/t_product_v1/7d59c04b-49fd-4904-b8e2-03fab7102ee4/blazer-mid-77-%E5%A5%B3%E5%AD%90%E8%BF%90%E5%8A%A8%E9%9E%8B-sTd61w.jpg","2.jpg");
       TestThread02 t3 = new TestThread02("https://static.nike.com/a/images/c_limit,w_592,f_auto/t_product_v1/e056586b-2660-4d96-b9eb-4e68f19a2312/lebron-18-nrg-%E5%A4%A7%E7%AB%A5%E7%AF%AE%E7%90%83%E7%AB%A5%E9%9E%8B-5BKwSZ.jpg","3.jpg");
       t1.start();
       t2.start();
       t3.start();
  }
}

//下载器
class WebDownloader{
   //下载方法
   public void downloader(String url,String name){
       try {
           FileUtils.copyURLToFile(new URL(url),new File(name));
      } catch (IOException e) {
           e.printStackTrace();
           System.out.println("IO异常,downloader");
      }

  }
}

 

Runnable 接口

package demo01;

//实现runnable接口,重写run方法,执行线程需要丢入runnable接口实现类,调用start方法
public class TestThread03 implements Runnable{

   @Override
   public void run() {
       //run方法线程体
       for (int i = 0; i < 200; i++) {
           System.out.println("git"+i);
      }
  }

   public static void main(String[] args) {
       //创建runnable接口的实现类对象
      TestThread03 testThread03 = new TestThread03();
       //创建线程对象,通过线程对象来开启我们的线程,代理
       //Thread thread = new Thread(testThread03);
       //thread.start();
       new Thread(testThread03).start();

       for (int i = 0; i < 1000; i++) {
           System.out.println("study"+i);
      }
  }
}

 

并发问题

package demo01;

import oop.demo07.Test;

//多线程同时操作同一个对象
public class TestThread04 implements Runnable{

   private int ticketNums = 10;

   @Override
   public void run() {
       while (true){
           if (ticketNums<=0){
               break;
          }
           try {
               Thread.sleep(200);
          } catch (InterruptedException e) {
               e.printStackTrace();
          }
           System.out.println(Thread.currentThread().getName()+"get"+ticketNums--);
      }
  }

   public static void main(String[] args) {
       TestThread04 ticket = new TestThread04();
       new Thread(ticket,"ming").start();
       new Thread(ticket,"huang").start();
       new Thread(ticket,"niu").start();
  }
}

 

Callable 接口

上一篇:Day09-Java基础语言-类型转换


下一篇:Day09,基本运算符,三元运算符小结