一操作系统中线程和进程的概念
现在的操作系统是多任务操作系统多线程是实现多任务的一种方式
进程是指一个内存中运行的应用程序每个进程都有自己独立的一块内存空间一个进程中可以启动多个线程比如在Windows系统中一个运行的exe就是一个进程线程是指进程中的一个执行流程一个进程中可以运行多个线程比如javaexe进程中可以运行很多线程线程总是属于某个进程进程中的多个线程共享进程的内存同时执行是人的感觉在线程之间实际上轮换执行
二Java中的线程
在Java中线程指两件不同的事情
javalangThread类的一个实例
线程的执行
使用javalangThread类或者javalangRunnable接口编写代码来定义实例化和启动新线程一个Thread类实例只是一个对象像Java中的任何其他对象一样具有变量和方法生死于堆上Java中每个线程都有一个调用栈即使不在程序中创建任何新的线程线程也在后台运行着一个Java应用总是从main()方法开始运行mian()方法运行在一个线程内它被称为主线程一旦创建一个新的线程就产生一个新的调用栈线程总体分两类用户线程和守候线程
当所有用户线程执行完毕的时候JVM自动关闭但是守候线程却不独立于JVM守候线程一般是由操作系统或者用户自己创建的
———————————MultiTjava——————————————————————
class MultiThread
{
public static void main(String[] args)
{
MyThread mt=new MyThread();
//mtsetDaemon(true);//设定为后台线程main进程结束时后台进程也跟着结束
//mtsetPriority(ThreadMAX_PRIORITY); //设定线程优先级MAX_PRIORITY为MIN_PRIORITY为NORM_PRIORITY为
//设定为最高优先级后程序运行时mt线程一直运行强制终止时main线程才运行
//设定为最高优先级的线程无论有无yield();线程总一直运行直到强制终止时main和mt线程交替运行
mtstart();
int index=;
while(true) //显示结果与教程不同
{
if(index++==)
break;
Systemoutprintln(main:+ThreadcurrentThread()getName()); //获取线程名字
}
}
}
class MyThread extends Thread
{
public void run()
{
while(true)
{
Systemoutprintln(getName());
yield(); //允许当前线程停止转去执行其他线程静态方法
//mt进程执行时切换到main进程main进程执行一段时间后
//切换进程到mtmt执行完获取名字后返回到main进程
}
}
}
//一个长时间处于等待状态的线程也有可能被线程调度器调度从而运行
//打破高优先级线程始终获有运行时间的状态
——————————————————————————————————————
——————————MultiThreadjava———————————————————————
class MultiThread
{
public static void main(String[] args)
{
MyThread mt=new MyThread();
//new Thread(mt)start(); //创建多个同样的线程访问同一个变量index若MyThread采用继承Thread方式则无法共享同一个变量
//new Thread(mt)start();
//new Thread(mt)start();
//new Thread(mt)start();
mtgetThread()start(); //也可以采用内部类的方式共享访问同一个变量
mtgetThread()start();
mtgetThread()start();
mtgetThread()start();
//mtsetDaemon(true);//设定为后台线程main进程结束时后台进程也跟着结束
//mtsetPriority(ThreadMAX_PRIORITY); //设定线程优先级MAX_PRIORITY为MIN_PRIORITY为NORM_PRIORITY为
//设定为最高优先级后程序运行时mt线程一直运行强制终止时main线程才运行
//设定为最高优先级的线程无论有无yield();线程总一直运行直到强制终止时main和mt线程交替运行
//mtstart();
int index=;
while(true) //显示结果与教程不同
{
// if(index++==)
// break;
Systemoutprintln(main:+ThreadcurrentThread()getName()); //获取线程名字
}
}
}
class MyThread //implements Runnable //extends Thread //使用外部类的方式
//使用内部类完成使用Runnable接口才能完成的两个功能 a创建多个线程b访问同一个变量
{
int index=;
private class InnerThread extends Thread //不想让外部访问其实现方法加上private
{
public void run()
{
while(true)
{
Systemoutprintln(ThreadcurrentThread()getName()+:+index++);
}
}
}
Thread getThread()
{
return new InnerThread();
}
/*
public void run()
{
while(true)
{
Systemoutprintln(ThreadcurrentThread()getName()+:+index++);
//yield(); //允许当前线程停止转去执行其他线程静态方法
//mt进程执行时切换到main进程main进程执行一段时间后
//切换进程到mtmt执行完获取名字后返回到main进程
}
}
*/
}
//一个长时间处于等待状态的线程也有可能被线程调度器调度从而运行
//打破高优先级线程始终获有运行时间的状态
//如果不需要修改Thread类的除了run方法外的其他方法选用implements Runnable
———————————————————————————————————————
———————————TicketsSystemjava———————————————————
//多线程实现火车票的售票系统 用同步块或着同步方法
class TicketsSystem
{
public static void main(String[] args) //运行结果与教程中不同不完全顺序每次运行顺序都不完全一样
{
SellThread st=new SellThread();//创建四个线程访问同一变量tickets
// 错 SellThread st=new SellThread();//若采用创建四个对象的方式则每个对象中都有张票
new Thread(st)start(); //b为false用的同步方法 | //同步方法与同步块共用中显示的是只调用了同步块而同步方法未被调用
//b为true用的同步块 | //原因启动第一个线程后CPU时间片没有到期线程没有立即运行接着执行b=true
// | //解决办法启动第一个线程后执行一个睡眠时间让CPU时间片到期
try
{
Threadsleep();
}
catch(Exception e)
{
eprintStackTrace();
}
stb=true;
new Thread(st)start();
//new Thread(st)start();
//new Thread(st)start();
}
}
class SellThread implements Runnable //程序有点小问题当剩下最后一张票时四个线程都运行可能会出现票数为（系统长时间运行时）
//可加上一个静态方法sleep();它会抛出异常
{
int tickets=;
//Object obj=new Object();//也可以声明一个Thread对象
Thread th=new Thread();
boolean b=false;
public void run()
{
if(b==false)
{
while(true)
sell();
}
else
{
while(true)
{ //同步方法利用的是this所代表的对象的锁
synchronized(this) //采用同步后显示正确此方法两步声明Thread对象用synchronized把原方法括起来
{ //这里换th为this
///*
if(tickets>)
{
try
{
Threadsleep();
}
catch(Exception e)
{
eprintStackTrace();
}
Systemoutprintln(th +ThreadcurrentThread()getName()+ sell tickets:+tickets);
tickets;
}
//*/
}
}
}
}
public synchronized void sell() //每个class也有一个锁是这个class所对应的class对象的锁（监视器）
{
if(tickets>)
{
try
{
Threadsleep();
}
catch(Exception e)
{
eprintStackTrace();
}
Systemoutprintln(sell +ThreadcurrentThread()getName()+ sell tickets:+tickets);
tickets;
}
}
}
————————————————————————————————————————
———————————TestWNjava————————————————————
class Test
{
public static void main(String[] args)
{
Queue q=new Queue();
Producer p=new Producer(q);
Consumer c=new Consumer(q);
pstart();
cstart();
}
}
class Producer extends Thread
{
Queue q;
Producer(Queue q)
{
thisq=q;
}
public void run()
{
for(int i=;i<;i++)
{
qput(i);
Systemoutprintln(Producer put: +i);
}
}
}
class Consumer extends Thread
{
Queue q;
Consumer(Queue q)
{
thisq=q;
}
public void run()
{
while(true)
{
Systemoutprintln(Consumer get: +qget());
}
}
}
class Queue //waitnotify方法必须用在同步方法中要加上关键字synchronized
{
int value;
boolean bFull=false;
public synchronized void put(int i)
{
if(!bFull)
{
value=i;
bFull=true;
notify();
}
try
{
wait();
}
catch(Exception e)
{
eprintStackTrace();
}
}
public synchronized int get()
{
if(!bFull)
{
try
{
wait();
}
catch(Exception e)
{
eprintStackTrace();
}
}
bFull=false;
notify();
return value;
}
}
————————————————————————————————————
————————————TestThreadjava———————————————————————
class TestThread
{
public static void main(String[] args)
{
Thread t=new Thread();
tstart();
int index=;
while(true)
{
if(index++==)
{
tstopThread();
tinterrupt(); //让线程终止
break;
}
Systemoutprintln(ThreadcurrentThread()getName());
}
Systemoutprintln(main() exit);
}
}
class Thread extends Thread
{
private boolean bStop=false;
public synchronized void run()
{
while(!bStop)
{
try
{
wait(); //加入wait后main线程结束时程序还未终止原因是Thread的线程调用wait方法进入对象的等待队列中需要notify方法将它唤醒
}
catch(Exception e)
{
//eprintStackTrace();
if(bStop)
return;
}
Systemoutprintln(getName());
}
}
public void stopThread()
{
bStop=true;
}
}
——————————————————————————————————————
