1.线程、进程

1.1 概念

进程:引入:为了程序能够并发执行,且为了对并发执行的程序加以描述和控制,引入了进程的概念。

  (1)进程是程序的一次执行。

  (2)进程是一个程序及其数据在处理机上顺序执行时所发生的活动。

  (3)进程是程序在一个数据集合上运行的过程,它是系统进行资源分配和调度的一个独立单位。

  (4)进程是作为能够拥有资源和独立运行的基本单位。

线程:  引入:在操作系统中引入线程,是为了减少程序并发执行时锁付出的空间开销,使OS具有更好的并发性。1.2

1.2 线程与进程进行比较

  线程具有许多传统进程所具有的特征,所以又称为轻量级进程或进程元,相应的把进程称为重量级的进程,传统进程相当于只有一个线程的任务,在引入了新城的操作系统中,通常一个进程都拥有若干个线程,至少也有一个线程。

  相同点:

  (1)调度:

  (2)并发性:在引入了线程的操作系统中,进程之间或一个线程中的多个线程之间都可以并发执行。

  (3)拥有资源:不论是传统的操作系统还是引入了线程的操作系统,进程都可以拥有资源,是系统中拥有资源的有个基本单位。

  (4)系统开销:在某些操作系统中,线程的切换、同步和通信都无需操作系统内核的干预。

  不同点

  (1)调度:在传统操作系统中,进程是拥有资源的基本和独立调度、分派的基本单位,在引入了线程的操作系统中,线程是调度和分派的基本单位,而进程是拥有资源的基本单位。

  (2)并发性:

  (3)拥有资源:进程拥有资源,线程自己不拥有资源(也有一点必不可少的资源)。但可以吧访问其他隶属进程的资源。

  (4)系统开销:

    a.在创建或撤销进程的时候,系统都要为之创建和回收进程控制块,分配或回收资源。如内存空间和I/O设备,系统开销明显大于线程创建或撤销时的开销。

    b.在进程切换时,涉及到当前进程CPU环境的保存及新被调度运行进程的CPU环境的设置,而线程的切换则仅需要保存和设置少量寄存器内容,不涉及存储器管理方面的操作,所以,进程的代价远高于线程。

    c.一个进程的多个线程具有相同的地址空间,在同步和通信的实现方面线程也比进程容易。

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

  (6)进程和线程的主要差别在于它们是不同的操作系统资源管理方式。进程有独立的地址空间,一个进程崩溃后,在保护模式下不会对其它进程产生影响,而线程只是一个进程中的不同执行路径。线程有自己的堆栈和局部变量,但线程之间没有单独的地址空间,一个线程死掉就等于整个进程死掉,所以多进程的程序要比多线程的程序健壮。

  (7)每个独立的线程都有一个程序运行的入口,顺序执行序列和程序的入口,但是线程不能够独立执行,必须依存在应用程序中,由应用程序提供多个线程执行控制。

1.3 线程的生命周期

1.3.1.线程处于就绪状态有以下几种方法

  (1)调用sleep()方法

  (2)调用wait()方法

  (3)等待输入/输出完成

1.3.2.当线程处于就绪状态后,可以用以下几种方法使线程进入运行状态:

  (1)线程调用notify()方法

  (2)线程调用notifyAll()方法

  (3)线程调用interrupt()方法

  (4) 线程的休眠时间结束

  (5)输入/输出结束

  线程生命周期状态图:

              继承Thread类-LMLPHP

2.线程的调度与控制

2.1 线程优先级

  java虚拟机主要负责则线程的调度,获取CPU的使用权,目前有两种调度模型:分时调度模型和抢占调度模型;java使用抢占调度模型。

  分时调度模型:所有线程轮流使用CPU的使用权,平均分配给每个线程占用CPU的时间片。

  抢占调度模型:优先让优先级高的线程使用CPU,如果线程的优先级相同,那么随机选择一个,优先极高的线程获得的CPU时间片相对多些。

例:

 /*
线程优先级高的获取的时间片相对高
*/
class Threadtest04
{
public static void main(String[] args)
{
//线程优先级
System.out.println(Thread.MAX_PRIORITY); //10 优先级最高
System.out.println(Thread.MIN_PRIORITY); //1 优先级最低
System.out.println(Thread.NORM_PRIORITY); //5 默认优先级
Thread t1 = new P();
t1.setName("t1"); Thread t2 = new P();
t2.setName("t2"); System.out.println(t1.getPriority()); //默认优先级为5
System.out.println(t2.getPriority()); //默认优先级为5
//设置优先级
t1.setPriority(4);
t2.setPriority(9); System.out.println(t1.getPriority()); //默认优先级为5
System.out.println(t2.getPriority()); //默认优先级为5
//启动线程
t1.start();
t2.start();
}
} class P extends Thread
{
public void run()
{
for(int i=0;i<10;i++)
{
System.out.println(Thread.currentThread().getName()+"..."+i);
}
}
}
/*
运行结果:
10
1
5
5
5
4
9
t1...0
t2...0
t1...1
t2...1
t1...2
t2...2
t1...3
t2...3
t1...4
t2...4
t1...5
t2...5
t1...6
t2...6
t1...7
t2...7
t1...8
t2...8
t1...9
t2...9
请按任意键继续. . . */

2.2 sleep方法

  sleep和wait的区别:

(1)所属类不同

Thread.sleep() ;   Object.wait()

(2)对于线程已经占有资源的处理

sleep在休息的时候,不释放资源 ; wait在等待的时候释放自己占用的资源

  例:

 /*
1.thread.sleep(毫秒)
2.sleep方法是一个静态方法
3.该方法作用:阻塞当前线程,将CPU让给其他线程
*/
class Threadtest05
{
public static void main(String[] args) throws InterruptedException
{
Thread t1 = new P();
t1.setName("t1");
t1.start();
Thread.sleep(5000);
//t1.interrupt();打断线程的睡眠
for(int i = 0;i<10;i++)
{
System.out.println(Thread.currentThread().getName()+".."+i);
Thread.sleep(500);//阻塞主线程0.5秒
}
}
} class P extends Thread
{
//被重写的方法不能抛出异常,在run方法的声明为置上不能呢使用Throws,
public void run()
{
for(int i = 0;i<10;i++)
{ try{
Thread.sleep(1000);//让当前线程阻塞1s
}catch(InterruptedException e)
{
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+".."+i);
}
}
}
/*
运行结果:
main..0
t1..0
main..1
t1..1
main..2
main..3
main..4
t1..2
main..5
t1..3
main..6
main..7
t1..4
main..8
main..9
t1..5
t1..6
t1..7
t1..8
t1..9
请按任意键继续. . . */

2.3 yield方法

  使用yield方法,与sleep方法类似,不能由用户指定暂停多长时间,并且yield方法只能让同优先级的线程由执行机会,让位时间不固定。静态方法

2.4 Join方法

  合并线程

3.创建线程的三种方法

  Java使用Thread类代表线程,所有的线程对象都必须是Thread类或其子类的实例。Java可以用三种方式来创建线程,如下所示:

  (1)继承Thread类创建线程

  (2)实现Runnable接口创建线程

  (3)使用Callable和Future创建线程

3.1.概念及特点

  (1).概念

  进程:计算机运行的应用程序。(多进程作用:提高CPU的使用率,不提高速度);

  线程;一个进程中的执行场景,一个进程可以包多个线程。(多线程作用:提高应用程序的使用率,不提高速度)。

  (2).内存特点

  进程和进程之间的内存是独立的;

  线程和线程共享“堆内存的方法区内存”,栈内存是独立的,一个线程一个栈。

  (3).java程序的运行原理

  Java命令启动Java虚拟机,启动JVM,等同于启动了一个应用程序,表示启动了一个进程,该进程会自动启动一个“主线程”,然后主线程去调用某个类的main方法,所 以main方法运行在主线程中。

3.2 线程的创建和启动

3.2.1 实现多线程的第一种方式

  Thread类在包java.lang中,从这个类中实例化的对象代表线程,启动一个新线程需要建立Thread实例,Thread类中常用的两个构造方法如下:

  (1)public Thread(String threadName)

  (2)public Thread()

  其中第一个构造方法是创建一个名称为threadName的线程对象

  创建一个新的线程的语法如下:

 public class ThreadTest extends Thread{}

  完成线程真正功能的代码方法类run()方法中,当一个类继承Thread类后,就可以在该类中覆盖run方法,将实现该线程功能的代码写入run()方法中国,然后调用Thread类中的start()方法执行线程,即调用run()方法.

  Thread对象需要一个任务来执行,任务是指线程在启动时执行的工作,该工作的功能代码被写在run()方法中。当执行一个线程程序时,就自动产生一个线程,主方法是在这个线程上运次的,当不再启动其他线程时,该程序就为单线程程序。

   以下是一个Thread类的实例:

/**
* 类ThreadTest继承继承Thread雷诺方法创建线程
* @author z
*
*/
public class ThreadTest extends Thread {
private int count = 10;
public void run(){
while(true){
System.out.println(count+"");
if(--count == 0){
return;
}
}
}
public static void main(String[] args){
new ThreadTest().start(); }
}

  运行结果:10 9 8 7 6 5 4 3 2 1

  分析:

  在上例中,继承了Thread类,然后覆盖了run()方法,通常在run()方法中使用无限循环的形式,使得线程一直运行下去,所以要指定一跳出循环的条件,本例使用变量count递减为0的方法跳出循环条件。

  在main()方发中,使线程执行需要调用Thread类中的start()方法,start()方法调用被覆盖的run()方法,如果不调用start()方法,线程永远不会启动,在主方法没有调用stsrt()方法之前,Thread()对象只是一个实例,而不是一个正真的线程。

再举一个例子:

  第一步: 继承Java.lang.Thread

  第二步;重写run方法

  例:

 class  Threadtest01
{
public static void main(String[] args) //main方法在主线程
{
//1.创建线程
Thread t = new p();
//2.启动线程
t.start(); /*启动t线程,执行后,t线程瞬间结束,JVM再分配一个新的栈给t线程
run方法不需要手动调用,系统线程启动之后自动调用run方法。*/ for(int i=0;i<100;i++) //在主线程中运行
{
System.out.println("main....."+i);
}
}
}
/*
在多线程中,main方法结束后只是主线程踪没有方法栈帧了,但
其他线程中或者其他栈中还有栈帧,main方法结束,程序可能还在运行
*/ //3.定义一个线程
class p extends Thread
{
//重写run方法
public void run ()
{
for(int i=0;i<100;i++)
{
System.out.println("run...."+i);
}
}
}
/*
运行部分结果如下:
main.....0
main.....1
main.....2
run....0
main.....3
run....1
main.....4
run....2
main.....5
run....3
main.....6
run....4
main.....7
run....5
main.....8
run....6
*/

  上述代码的图解如下:

继承Thread类-LMLPHP

3.3.2 实现多线程的第二种方式:

  Runnable接口的说用是使线程不仅可以继承Thread类实现,还可以继承其他类(比如:JFrame)。

  此接口具有两个构造方法:

  (1)public Thread(Runnable r)

  (2)public Thread(Runnable r,String name).

  这两个构造方法的参数中都存在Runnable实例,使用构造方法就可以将Runnable实例与Thread实例相关联。

  使用Runnable的步骤如下:

  (1)建立Runnable对象

  (2)使用参数为Runnable对象的构造方法创建Thread实例

  (3)调用start()方法。

  例:在项目中创建SwingAndThread类,该类继承了JFrame类,实现图标移动的功能,其中使用了Swing与线程相结合的技术:

 import java.awt.*;
import java.net.*; import javax.swing.*; public class SwingAndThread extends JFrame {
/**
*
*/
private static final long serialVersionUID = 1L;
private JLabel jl = new JLabel(); // 声明JLabel对象
private static Thread t; // 声明线程对象
private int count = 0; // 声明计数变量
private Container container = getContentPane(); // 声明容器 public SwingAndThread() {
setBounds(300, 200, 250, 100); // 绝对定位窗体大小与位置
container.setLayout(null); // 使窗体不使用任何布局管理器
URL url = SwingAndThread.class.getResource("/1.gif"); // 获取图片的URL
Icon icon = new ImageIcon(url); // 实例化一个Icon
jl.setIcon(icon); // 将图标放置在标签中
// 设置图片在标签的最左方
jl.setHorizontalAlignment(SwingConstants.LEFT);
jl.setBounds(10, 10, 200, 50); // 设置标签的位置与大小
jl.setOpaque(true);
t = new Thread(new Runnable() { // 定义匿名内部类,该类实现Runnable接口
public void run() { // 重写run()方法
while (count <= 200) { // 设置循环条件
// 将标签的横坐标用变量表示
jl.setBounds(count, 10, 200, 50);
try {
Thread.sleep(1000); // 使线程休眠1000毫秒
} catch (Exception e) {
e.printStackTrace();
}
count += 4; // 使横坐标每次增加4
if (count == 200) {
// 当图标到达标签的最右边,使其回到标签最左边
count = 10;
}
}
}
});
t.start(); // 启动线程
container.add(jl); // 将标签添加到容器中
setVisible(true); // 使窗体可视
// 设置窗体的关闭方式
setDefaultCloseOperation(WindowConstants.DISPOSE_ON_CLOSE);
} public static void main(String[] args) {
new SwingAndThread(); // 实例化一个SwingAndThread对象
}
}

  运行结果:

  继承Thread类-LMLPHP

  再举一个例子:

  第一步:写一个实现类java,lang.Runnable;接口

  第二步:实现run方法

  例:

 package test;

 class Main
{
public static void main(String[] args)
{
//创建线程
Thread t = new Thread(new p());
//启动线程
t.start();
for(int i = 0;i<100;i++)
System.out.println("mian..."+i); }
}
//优先,一个类实现接口之外保留了类的继承
class p implements Runnable
{
public void run()
{
for(int i = 0;i<100;i++)
System.out.println("run..."+i);
}
}
/*
* 部分运行结果:
* run...8
mian...10
run...9
mian...11
run...10
mian...12
run...11
mian...13
run...12
*/

4.线程的同步(加锁)

4.1 基本概念及特点

(1)概念:

  a.线程同步,是指某一个时刻,只允许一个线程访问共享资源,线程同步实际上是对对象加锁,如果对象中的方法都是同步方法,那么某一时刻只能执 行一个方法,采用线程同步解决以上问题;  为了数据安全,尽管应用程序的使用效率降低,但是为了数据安全,必须加入线程同步机制,线程同步机制使程序等同于单线程。

  b.异步编程模型:多个线程分别执行,各线程互不影响。

  c.同步编程模型:多个线程执行只有一个线程执行结束才能执行另一个线程。(作用:达到数据安全)

(2)使用线程同步机制的条件:

  a:必须是多线程环境

  b:多线程环境共享一个数据

  c:共享的数据涉及到数据的修改

4.2 举例

  例1:(对象锁,方法一,控制精确,常用)

 /*
模拟银行取款系统:对于同一个账号,用两个线程同时对其取款。
*/
class Threadtest06
{
public static void main(String[] args)
{
//创建公共账号
Account act = new Account("账号sss",10000);
//创建两个线程对同一个账户取款
Thread t1 = new Thread(new P(act));
Thread t2 = new Thread(new P(act));
t1.start();
t2.start();
}
}
//取款线程
class P implements Runnable
{
//账户
Account act;
P(Account act)
{
this.act = act;
}
public void run()
{
act.withdraw(2000);
System.out.println("取款成功,余额为:"+act.getBalance());
} }
//账户
class Account
{
private String action;
private double balance;
public Account(){}
public Account(String action,double balance){
this.action = action;
this.balance = balance;
}
public void setAction(String action)
{
this.action = action;
} public void setBalance(double balance)
{
this.balance = balance;
}
public String getAction(String action)
{
return action;
}
public double getBalance()
{
return balance;
}
public void withdraw(double money)
{
synchronized(this){ //this表示共享对象
double after = balance - money;
try{
Thread.sleep(1000);
}catch(Exception e){}
this.setBalance(after);
}
}
} /*
运行结果:
取款成功,余额为:8000.0
取款成功,余额为:6000.0
请按任意键继续. . . */

  上例原理:   t1线程执行到synchronized关键字处,就会去找this对象锁,如果找到this对象锁,就回进入同步语句块中执行,当同步语句块中的代码执行结束后,

  t1线程归还this对象锁。在t1线程执行同步语句块的过程中,如果t2线程也过来执行此代码,也遇到synchronized关键字,所以也去找this对象锁,但是

  该对象锁被t1线程持有,只能等待this对象的归还。

  例2;synchronized关键字添加到成员方法上,线程拿到的扔是this的对象锁(对象锁,方法二,执行效率低)

 /*
模拟银行取款系统:对于同一个账号,用两个线程同时对其取款。
*/
class Threadtest06
{
public static void main(String[] args)
{
//创建公共账号
Account act = new Account("账号sss",10000);
//创建两个线程对同一个账户取款
Thread t1 = new Thread(new P(act));
Thread t2 = new Thread(new P(act));
t1.start();
t2.start();
}
}
//取款线程
class P implements Runnable
{
//账户
Account act;
P(Account act)
{
this.act = act;
}
public void run()
{
act.withdraw(2000);
System.out.println("取款成功,余额为:"+act.getBalance());
} }
//账户
class Account
{
private String action;
private double balance;
public Account(){}
public Account(String action,double balance){
this.action = action;
this.balance = balance;
}
public void setAction(String action)
{
this.action = action;
} public void setBalance(double balance)
{
this.balance = balance;
}
public String getAction(String action)
{
return action;
}
public double getBalance()
{
return balance;
}
public synchronized void withdraw(double money)
{ double after = balance - money;
try{
Thread.sleep(1000);
}catch(Exception e){}
this.setBalance(after); }
} /*
运行结果:
取款成功,余额为:8000.0
取款成功,余额为:6000.0
请按任意键继续. . . */

  (另:StirngBuffer  Vector Hashtable 是线程安全的 )

5.死锁

  例:

 /*
死锁
*/
class DeadLook
{
public static void main(String[] args)
{
Object o1 = new Object();
Object o2 = new Object(); Thread t1 = new Thread(new T1(o1,o2));
Thread t2 = new Thread(new T2(o1,o2));
t1.start();
t2.start();
}
} class T1 implements Runnable
{
Object o1;
Object o2;
T1(Object o1,Object o2)
{
this.o1 = o1;
this.o2 = o2;
}
public void run()
{
synchronized(o1)
{
try{Thread.sleep(1000);}catch(Exception e){}
synchronized(o2)
{
System.out.println("t1");
}
}
}
}
class T2 implements Runnable
{
Object o1;
Object o2;
T2(Object o1,Object o2)
{
this.o1 = o1;
this.o2 = o2;
}
public void run()
{
synchronized(o2)
{
try{Thread.sleep(1000);}catch(Exception e){}
synchronized(o1)
{
System.out.println("t2");
}
}
}
}

6.守护线程

  从线程的分类上可以分为:用户线程和守护线程,所有的用户线程结束生命周期,只有一个用户线程存在,那么守护线程就不会结束,Java中的垃圾回收器就

  是一个守护线程,只有应用程序中所有的线程结束,它才会结束。

  例:

 /*
守护线程:
所有的用户线程结束,守护线程才会结束,守护线程是一个无限循环执行的。
*/
class Threadtest08
{
public static void main(String[] args) throws Exception
{
Thread t1 = new P();
t1.setName("t1");
t1.setDaemon(true);//将用户线程修改为守护线程
t1.start();
//主线程
for(int i = 0;i < 10; i++)
{
System.out.println(Thread.currentThread().getName()+".."+i);
Thread.sleep(1000);
}
}
} class P extends Thread
{
public void run()
{
int i = 0;
while(true)
{
i++;
System.out.println(Thread.currentThread().getName()+".."+i);
try{Thread.sleep(1000);}catch(Exception e){}
}
}
}
/*
运行结果:
main..0
t1..1
t1..2
main..1
t1..3
main..2
main..3
t1..4
main..4
t1..5
main..5
t1..6
main..6
t1..7
main..7
t1..8
main..8
t1..9
main..9
t1..10
请按任意键继续. . . */

7.Timer定时器

  作用:每隔一段固定的时间执行一段代码

  例:

 /*
定时器
*/
import java.text.*;
import java.util.*;
class Timertest
{
public static void main(String[] args) throws Exception
{
//创建定时器
Timer t = new Timer();
//指定定时任务
t.schedule(new LogTimerTask(),new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS").parse("2017-04-21 11:42:00 000"),10*1000); }
}
//指定任务
class LogTimerTask extends TimerTask
{
public void run()
{
System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS").format(new Date()));
}
}

8.线程池

   参考资料   http://www.importnew.com/19011.html

                    http://lavasoft.blog.51cto.com/62575/27069/

                    https://mp.weixin.qq.com/s?__biz=MzI1NDQ3MjQxNA==&mid=2247484346&idx=1&sn=f065ebd404771a90988bb097ea4e26dd&chksm=e9c5fa0bdeb2731d12b838372fc8aa97890dd2e3379d1a486df7cf795f8a1538c1ae974a13e7&mpshare=1&scene=23&srcid=1022Iecc2i96j9Drfxgzd274#rd

05-08 08:37