多线程之9——BlockingQueue (阻塞队列)

现有的程序代码模拟产生了16个日志对象，并且需要运行16秒才能打印完这些日志，请在程序中增加4个线程去调用parseLog()方法来分头打印这16个日志对象，程序只需要运行4秒即可打印完这些日志对象。原始代码如下：

public class Test {

public static void main(String[] args){



System.out.println("begin:"+(System.currentTimeMillis()/1000));

/*模拟处理16行日志，下面的代码产生了16个日志对象，当前代码需要运行16秒才能打印完这些日志。

修改程序代码，开四个线程让这16个对象在4秒钟打完。

*/

for(int i=0;i<16;i++){ //这行代码不能改动

final String log = ""+(i+1);//这行代码不能改动

{

Test.parseLog(log);

}

}

}

//parseLog方法内部的代码不能改动

public static void parseLog(String log){

System.out.println(log+":"+(System.currentTimeMillis()/1000));

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

分析: 由于有两行不能改动， 要创建线程只能在for循环 之外, 16条数据放在队列中，让4个线程去队列中抓取数据.。

要想在for之中创建数据， 并且交给在 for之外的4个线程， 只能是把数据放在一个容器中， 4个线程到 这个容器去取

解答:

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.BlockingQueue;

public class Test {

public static void main(String[] args) {

// 定义阻塞队列，队列一拿了，其它队列就不能拿已经拿了的数据, 这里定义了队列放16条数据, 如果设为1,则结果可能为有顺序1-16

final BlockingQueue<String> queue = new ArrayBlockingQueue<String>(16);

for (int i = 0; i < 4; i++) {

new Thread(new Runnable() {

@Override

public void run() {

// 在每个线程去取数据

try {

//去队列取数据，要加上while 循环, 指不断地取数据

while (true) {

// 从队列queue取数据，是调用take方法

String log = queue.take();

Test.parseLog(log);

}

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}).start();

}

System.out.println("begin:" + (System.currentTimeMillis() / 1000));

/*

* 模拟处理16行日志，下面的代码产生了16个日志对象，当前代码需要运行16秒才能打印完这些日志。

* 修改程序代码，开四个线程让这16个对象在4秒钟打完。

*/

for (int i = 0; i < 16; i++) { // 这行代码不能改动

final String log = "" + (i + 1);// 这行代码不能改动

{

try {

queue.put(log);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}

// parseLog方法内部的代码不能改动

public static void parseLog(String log) {

System.out.println(log + ":" + (System.currentTimeMillis() / 1000));

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}