java之玩转打印机

说在前面

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