说在前面
很喜欢并发,所以一直在学并发。这就是因为爱,所以爱了吧!对了,上次说到去南天的事情,我过了,还算对得起自己吧,毕竟连hr都当面夸我优秀,哈哈!
demo一之采用Lock锁仿一个打印机随机打印多个文件
PrinterDemo类
public class PrinterDemo {
public static void main(String[] args) {
work();
}
/**
* @描述:启动10个线程,分别模拟文本打印,分别打印出100个1-10
* @时间:下午6:19:14
* @开发者:稀饭
* @测试:
* @param
*/
public static void work()
{
Printer printer = new Printer();
for (int i = 1; i <= 10; i++) {
Thread thread1 = new Thread(new Job(printer, i+""));
thread1.start();
}
}
}
源码分析:在work函数中生成多个线程,让线程分别启动,并且传递的是同一个Printer对象,那么线程启动后做什么事情呢?请看下文!
Job类,线程类,调用打印机进行打印
public class Job implements Runnable{
private Printer printer;
private String index;
public Job(Printer printer,String index)
{
this.printer = printer;
this.index = index;
}
/** @Title: run
* @Description: TODO
*/
@Override
public void run() {
// TODO Auto-generated method stub
printer.work(index);
}
}
源码分析:线程会调用同一个Printer对象的work函数,用同一个Printer对象的目的在于营造只有一个打印机的情况,模拟实现一个打印机打印多份文件的过程。
Printer 类,充当打印机,实现打印功能
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Printer {
private final Lock quLock = new ReentrantLock();
public void work(String index)
{
quLock.lock();
for (int i = 0; i < 100; i++) {
System.out.print(index);
try {
Thread.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println();
quLock.unlock();
}
}
源码分析:在这里模拟实现了打印的过程,大家应该都观察到了Lock quLock = new ReentrantLock(),其实我就是用了一个锁对象,锁对象调用lock函数(quLock.lock())将打印机进行上锁,目的就是为了让打印机在打印文件开始的时候是隔离的,不会因为其他的打印工作进来后就产生混乱。
demo二之采用信号灯锁仿一个打印机随机打印多个文件
Printer 类,充当打印机,实现打印功能
import java.util.concurrent.Semaphore;
public class Printer {
private final Semaphore semaphore = new Semaphore(1);
public void work(String index)
{
try {
semaphore.acquire();
for (int i = 0; i < 100; i++) {
System.out.print(index);
try {
Thread.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println();
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}finally {
semaphore.release();
}
}
}
源码分析:在源码中可以看到定义了Semaphore这个对象来实现二进制信号量,它可以用来保护对唯一共享资源的访问,这个Printer对象受Semaphore这个对象保护所以同时只有一个线程可以执行打印。使用步骤如下:
- 首先,必须通过acquire函数获得信号量,会抛出异常
- 其次,使用共享资源执行必要的操作
- 最后,必须通过release函数释放信号量
Note:发布的这些文章全都是自己边学边总结的,难免有纰漏,如果发现有不足的地方,希望可以指出来,一起学习咯,么么哒。
开源爱好者,相信开源的力量必将改变世界:
osc : https://git.oschina.net/xi_fan
github: https://github.com/wiatingpub
私人微信: 18814128405
网友评论