浅谈Java多线程的优点及代码示例
尽管面临很多挑战,多线程有一些优点使得它一直被使用。这些优点是:
资源利用率更好
程序设计在某些情况下更简单
程序响应更快
资源利用率更好
想象一下,一个应用程序需要从本地文件系统中读取和处理文件的情景。比方说,从磁盘读取一个文件需要5秒,处理一个文件需要2秒。处理两个文件则需要:
5秒读取文件a 2秒处理文件a 5秒读取文件b 2秒处理文件b --------------------- 总共需要14秒
从磁盘中读取文件的时候,大部分的cpu时间用于等待磁盘去读取数据。在这段时间里,cpu非常的空闲。它可以做一些别的事情。通过改变操作的顺序,就能够更好的使用cpu资源。看下面的顺序:
5秒读取文件a 5秒读取文件b + 2秒处理文件a 2秒处理文件b --------------------- 总共需要12秒
cpu等待第一个文件被读取完。然后开始读取第二个文件。当第二文件在被读取的时候,cpu会去处理第一个文件。记住,在等待磁盘读取文件的时候,cpu大部分时间是空闲的。
总的说来,cpu能够在等待io的时候做一些其他的事情。这个不一定就是磁盘io。它也可以是网络的io,或者用户输入。通常情况下,网络和磁盘的io比cpu和内存的io慢的多。
程序设计更简单
在单线程应用程序中,如果你想编写程序手动处理上面所提到的读取和处理的顺序,你必须记录每个文件读取和处理的状态。相反,你可以启动两个线程,每个线程处理一个文件的读取和操作。线程会在等待磁盘读取文件的过程中被阻塞。在等待的时候,其他的线程能够使用cpu去处理已经读取完的文件。其结果就是,磁盘总是在繁忙地读取不同的文件到内存中。这会带来磁盘和cpu利用率的提升。而且每个线程只需要记录一个文件,因此这种方式也很容易编程实现。
程序响应更快
将一个单线程应用程序变成多线程应用程序的另一个常见的目的是实现一个响应更快的应用程序。设想一个服务器应用,它在某一个端口监听进来的请求。当一个请求到来时,它去处理这个请求,然后再返回去监听。
服务器的流程如下所述:
while(server is active){ listen for request process request }
如果一个请求需要占用大量的时间来处理,在这段时间内新的客户端就无法发送请求给服务端。只有服务器在监听的时候,请求才能被接收。另一种设计是,监听线程把请求传递给工作者线程(worker thread),然后立刻返回去监听。而工作者线程则能够处理这个请求并发送一个回复给客户端。这种设计如下所述:
while(server is active){ listen for request hand request to worker thread }
这种方式,服务端线程迅速地返回去监听。因此,更多的客户端能够发送请求给服务端。这个服务也变得响应更快。
桌面应用也是同样如此。如果你点击一个按钮开始运行一个耗时的任务,这个线程既要执行任务又要更新窗口和按钮,那么在任务执行的过程中,这个应用程序看起来好像没有反应一样。相反,任务可以传递给工作者线程(word thread)。当工作者线程在繁忙地处理任务的时候,窗口线程可以*地响应其他用户的请求。当工作者线程完成任务的时候,它发送信号给窗口线程。窗口线程便可以更新应用程序窗口,并显示任务的结果。对用户而言,这种具有工作者线程设计的程序显得响应速度更快。
下面是借鉴别人的一个java多线程的例子,感谢。
问题:三个售票窗口同时出售20张票;
程序分析:
1.票数要使用同一个静态值
2.为保证不会出现卖出同一个票数,要java多线程同步锁。
设计思路:1.创建一个站台类station,继承thread,重写run方法,在run方法里面执行售票操作!售票要使用同步锁:即有一个站台卖这张票时,其他站台要等这张票卖完!
创建主方法调用类
(一)创建一个站台类,继承thread
(原文有一点点小错误,小编已经更正,大家请放心测试使用)
package com.xykj.threadstation; public class station extends thread { // 通过构造方法给线程名字赋值 public station(string name) { super(name); // 给线程名字赋值 } // 为了保持票数的一致,票数要静态 static int tick = 20; // 创建一个静态钥匙 static object ob = "aa"; //值是任意的 // 重写run方法,实现买票操作 @override public void run() { while (tick > 0) { synchronized (ob) { // 这个很重要,必须使用一个锁, // 进去的人会把钥匙拿在手上,出来后才把钥匙拿让出来 if (tick > 0) { system.out.println(getname() + "卖出了第" + tick + "张票"); tick--; } else { system.out.println("票卖完了"); } } try { sleep(1000); //休息一秒 } catch (interruptedexception e) { e.printstacktrace(); } } } }
(二)创建主方法调用类
package com.xykj.threadstation; public class mainclass { /** * java多线程同步锁的使用 * 示例:三个售票窗口同时出售10张票 * */ public static void main(string[] args) { //实例化站台对象,并为每一个站台取名字 station station1=new station("窗口1"); station station2=new station("窗口2"); station station3=new station("窗口3"); // 让每一个站台对象各自开始工作 station1.start(); station2.start(); station3.start(); } }
运行结果:
窗口1卖出了第20张票 窗口2卖出了第19张票 窗口3卖出了第18张票 窗口1卖出了第17张票 窗口2卖出了第16张票 窗口3卖出了第15张票 窗口3卖出了第14张票 窗口2卖出了第13张票 窗口1卖出了第12张票 窗口3卖出了第11张票 窗口2卖出了第10张票 窗口1卖出了第9张票 窗口1卖出了第8张票 窗口2卖出了第7张票 窗口3卖出了第6张票 窗口1卖出了第5张票 窗口3卖出了第4张票 窗口2卖出了第3张票 窗口3卖出了第2张票 窗口2卖出了第1张票 票卖完了
总结
以上就是本文关于浅谈java多线程的优点及代码示例的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅:java多线程之线程通信生产者消费者模式及等待唤醒机制代码详解、java编程之多线程死锁与线程间通信简单实现代码、java多线程编程小实例模拟停车场系统等,有什么问题可以随时留言,小编会及时回复大家的。感谢朋友们对本站的支持!
上一篇: Java如何获取当前进程ID以及所有Java进程的进程ID
下一篇: Maven构建生命周期详细介绍