说在前面
很喜欢并发，所以一直在学并发。这就是因为爱，所以爱了吧！对了，上次说到去南天的事情，我过了，还算对得起自己吧，毕竟连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
