线程是什么呢?我们可以把一个应用比作是一个公司,然后一个线程就是公司里面的每一个员工,我们每个员工都在做自己的工作,从而使公司有条不乱的运作下去。要了解线程是什么,那么首先要了解进程是什么。进程是指一个内存中运行的应用程序,每个进程都有自己独立的一块内存空间,一个进程中可以有多个线程。比如在Windows系统中,一个运行的xx.exe就是一个进程。然后线程是指进程中的一个执行任务(控制单元),一个进程中可以运行多个线程,多个线程可共享数据。一个进程至少有一个线程,为了提高效率,可以在一个进程中开启多个线程。
进程与线程的区别:
1.进程有独立的进程空间,进程中的数据存放空间(堆空间和栈空间)是独立的。
2.线程的堆空间是共享的,栈空间是独立的,线程消耗的资源也比进程小,相互之间可以影响的。
创建线程的方法有两种:
一种是直接继承Thread类,它的步骤是:
1.创建一个类继承Thread
2.子类覆写父类中的run方法,将线程运行的代码存放在run中。
3.建立子类对象的同时线程也被创建。
4.通过调用start方法开启线程。
另一种方法是实现Runnable接口,它的步骤:
1.子类覆盖接口中的run方法。
2.通过Thread类创建线程,并将实现了Runnable接口的子类对象作为参数传递给Thread类的构造函数。
3.Thread类对象调用start方法开启线程。
线程Thread类中的重要方法:
CurrentThread();返回当前正在执行的线程对象的引用。
getName();返回该线程的名字。
getPriority();返回该线程的优先级。
IsAlive();测试该线程是否还活着。
Jion();等待该线程终止。
Jion(long million);等待该线程终止的时间最长为 millis 毫秒。
setPriority();更改该线程的优先级。
使用线程的例子:
有50张票需要3个窗口卖出。
代码如下:
package bokedemo;
public class SaleTicket {
public static void main(String[] args) {
//创建一个Runnable实例
Runnable runnable=new MyRunnable();
//开启3个线程卖票
new Thread(runnable,"1窗口").start();
new Thread(runnable,"2窗口").start();
new Thread(runnable,"3窗口").start();
}
}
/**
* 实现Runnable接口,覆写run方法。
* @author Cam
*
*/
class MyRunnable implements Runnable
{
int sum=50;
@Override
public void run() {
while(sum!=0)
{
System.out.println(Thread.currentThread().getName()+"卖了第"+sum--+"票");
}
}
}
下面说一下线程的生命周期:
新建:当程序使用new创建一个线程后,该线程处于新建状态,此时他和其他java对象一样,仅仅由Java虚拟机为其分配内存并初始化成员变量值。【 Thread r = new Thread() 】
就绪:当线程对象调用start()方法后,该线程处于就绪状态,线程计入线程队列排队,此时该状态线程并未开始执行,它仅表示可以运行了。至于该线程何时运行,取决于JVM线程调度器的调度。【 r.start() 】
运行:若处于就绪状态的线程获得了CPU,开始执行run()线程执行体,该线程处于执行状态。
阻塞:线程运行过程中需要被中断,目的是是其他的线程获得执行的机会。该状态就会进入阻塞状态。阻塞线程的方法有多种,主要有jion()、
Sleep()、Ojcect中的wait()。
下面用个例子说明一下jion方法的阻塞,代码如下:
package bokedemo;
public class ThreadStop {
public static void main(String[] args) {
MyThread1 thread1=new MyThread1();
Thread thread2=new MyThread2(thread1);
thread1.start();
thread2.start();
}
}
//使用继承Thread类的方法创建线程
class MyThread1 extends Thread
{
@Override
public void run() {
super.run();
for(int i=0;i<50;i++)
{
System.out.println("MyThread1:"+i);
try {
//为了对比效果明显,睡100毫秒
sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
class MyThread2 extends Thread
{
private MyThread1 mthread;
public MyThread2(MyThread1 mthread){
this.mthread=mthread;
}
@Override
public void run() {
super.run();
for(int i=0;i<50;i++)
{
System.out.println("MyThread2:"+i);
//当i等于25时调用MyThread1线程的jion方法,阻塞MyThread2线程
if(i==25)
try {
mthread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
|
|