/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package blockingqueuetest;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.util.Scanner;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
/**
*
* @author Administrator
*/
public class BlockingQueueTest {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
Scanner in = new Scanner(System.in);
System.out.print("Enter the base directory (e.g. /usr/local/jdk1.6.0/src)");
String directory = in.nextLine();
System.out.print("Enter keyword (e.g. volatile)");
String keyword = in.nextLine();
final int FILE_QUEUE_SIZE = 10;
final int SEARCH_THREADES = 100;
BlockingQueue<File> queue = new ArrayBlockingQueue<File>(FILE_QUEUE_SIZE);
//创建一个带有给定的(固定)容量和默认访问策略的 ArrayBlockingQueue
FileEnumerationTask enumerator = new FileEnumerationTask(queue, new File(directory));
new Thread(enumerator).start(); //该线程负责在指定目录下将所有文件加入阻塞队列
for(int i = 1; i <= SEARCH_THREADES; i++)
{
new Thread(new SearchTask(queue, keyword)).start(); //该线程用来搜索指定文件是否包含关键字
System.out.print(queue.size() + " ");
}
}
}
class FileEnumerationTask implements Runnable
{
private BlockingQueue<File> queue;
private File startingDirectory;
public static File DUMMY = new File("");
public FileEnumerationTask(BlockingQueue<File> queue, File startingDirectory) {
this.queue = queue;
this.startingDirectory = startingDirectory;
}
@Override
public void run() {
try
{
enumerate(startingDirectory);
queue.put(DUMMY);
}
catch(InterruptedException e)
{
}
}
/*
* 该函数的功能是遍历某个目录下(包括子目录)的文件,并将其加入到BlockingQueue中
*
**/
private void enumerate(File directory) throws InterruptedException
{
File[] files = directory.listFiles();
for(File f: files)
{
if(f.isDirectory())
enumerate(f);
else
queue.put(f);
}
}
}
/*
* SearchTask的功能是提供一个方法,搜索指定目录下包含指定关键字的文件。
*/
class SearchTask implements Runnable
{
private BlockingQueue<File> queue;
private String keyword;
public SearchTask(BlockingQueue<File> queue, String keyword) {
this.queue = queue;
this.keyword = keyword;
}
@Override
public void run() {
try {
boolean done = false;
while (!done) {
File file = queue.take();
if (file == FileEnumerationTask.DUMMY) {
queue.put(file);
done = true;
} else {
try {
search(file);
} catch (FileNotFoundException ex) {
}
}
}
} // catch(IOException e)
// {
// e.printStackTrace();
// }
catch (InterruptedException e)
{
}
}
private void search(File file) throws FileNotFoundException {
Scanner in = new Scanner(new FileInputStream(file));
int lineNumber = 0;
while(in.hasNext())
{
lineNumber++;
String line = in.nextLine();
if(line.contains(keyword))
System.out.printf("%s:%d:%s%n", file.getPath(), lineNumber, line);
}
in.close();
}
}
分享到:
相关推荐
java中,常用的阻塞式队列Demo。包含:ArrayBlockingQueue、LinkedQueue、PriorityBlockingQueue
实现java模拟阻塞队列的例子,该代码包括,阻塞队列实现生产者,消费者。和模拟阻塞队列实现生产者及消费者模式,帮助你更好的理解java多线程
支持多线程的阻塞队列,使用模板技术,可存储任意类型数据
Java实现简单的阻塞队列2种方式,1使用wait(),notify();2使用countdownlatch实现
并发-线程池和阻塞队列 并发-线程池和阻塞队列 并发-线程池和阻塞队列
讲述线程池原理,线程池使用场景和注意事项,手动创建线程池方法,注意事项,阻塞队列的相关知识
在前面我们接触的队列都是非阻塞队列,比如PriorityQueue、LinkedList(LinkedList是双向链表,它实现了Dequeue接口)。 使用非阻塞队列的时候有一个很大问题是:它不会对当前线程产生阻塞,那么在面对类似...
主要介绍了剖析Java中阻塞队列的实现原理及应用场景,这里也对阻塞和非阻塞队列的不同之处进行了对比,需要的朋友可以参考下
主要介绍了java阻塞队列实现原理及实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
主要介绍了C++数据结构与算法之双缓存队列实现方法,结合实例形式分析了双缓存队列的原理、实现方法与相关注意事项,需要的朋友可以参考下
c++11 实现的阻塞队列
PI解决队列堵塞问题
java阻塞队列实现原理及实例解析.docx
实现消息队列的关键因素是考量不同线程访问消息队列的同步问题。本实现涉及到几个知识点 std::lock_guard 介绍 std::lock_gurad 是 C++11 中定义的模板类。定义如下: template <class> class lock_guard; lock_...
没有网络的时候,将操作产生的本地图片(拍照,也可能是其他文件),存储起来。有网络的时候传输到文件服务器。 文件服务器只支持一个文件一个文件的传输。
基于Linux实现简单的队列功能。本代码实现了阻塞和非阻塞方式出入队列。同时是线程安全的。如果队列满,在入队时可以指定最大超时。如果队列空,可以在出队时指定最大超时。
阻塞队列实现生产者消费者模式Java开发Java经验技巧共4页.pdf.zip
14-阻塞队列BlockingQueue实战及其原理分析二.pdf
运行,登录时,请用两个浏览器登录,应为有不同session,这是跟据session来判断用户的
阻塞队列是多线程中常用的数据结构,对于实现多线程之间的数据交换、同步等有很大作用。 阻塞队列常用于生产者和消费者的场景,生产者是向队列里添加元素的线程,消费者是从队列里取元素的线程。简而言之,阻塞队列...