package com.queue;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.Scanner;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
/**
* 通过阻塞队列实现文件关键字检索功能
*
* @author benDaoRong
*/
public class BlockQueueTest {
public static void main(String[] args) {
String path = "F:/个人资料/书籍/TXT&PDF";
String keyword = "农夫";
final int FILE_QUEUE_SIZE = 10;// 阻塞队列大小
final int SEARCH_THREADS = 100;// 关键字搜索线程个数
BlockingQueue<File> queue = new ArrayBlockingQueue<File>(FILE_QUEUE_SIZE);
// 启动线程遍历文件
FileEnumerationTask enumeration = new FileEnumerationTask(queue, new File(path));
new Thread(enumeration).start();
// 启动线程检索关键字
for (int i = 0; i < SEARCH_THREADS; i++) {
new Thread(new SearchTask(queue, keyword)).start();
}
}
}
class FileEnumerationTask implements Runnable {
// 哑元文件对象,放在阻塞队列最后,用来标示文件已被遍历完
public static File DUMMY = new File("");
private BlockingQueue<File> queue;
private File startingDirectory;
public FileEnumerationTask(BlockingQueue<File> queue, File startingDirectory) {
this.queue = queue;
this.startingDirectory = startingDirectory;
}
/**
* 遍历指定目录下的所有文件以File对象的格式放入阻塞队列中
*
* @param directory
* @throws InterruptedException
*/
public void enumerate(File directory) throws InterruptedException {
if (directory == null) {
return;
}
if (directory.isDirectory()) {
File[] files = directory.listFiles();
for (File file : files) {
if (file.isDirectory()) {
enumerate(file);
}
else {
queue.put(file);
}
}
}
else {
queue.put(directory);
}
}
public void run() {
try {
enumerate(startingDirectory);
queue.put(DUMMY);
}
catch (InterruptedException e) {
e.printStackTrace();
}
}
}
class SearchTask implements Runnable {
private BlockingQueue<File> queue;
private String keyword;
public SearchTask(BlockingQueue<File> queue, String keyword) {
this.queue = queue;
this.keyword = keyword;
}
public void run() {
try {
while (true) {
File file = queue.take();
if (file == FileEnumerationTask.DUMMY) {
queue.put(file);
break;
}
else {
search(file);
}
}
}
catch (Exception e) {
e.printStackTrace();
}
}
public void search(File file) throws IOException {
if (file == null) {
return;
}
Scanner scanner = new Scanner(new FileInputStream(file));
int lineNumber = 0;
while (scanner.hasNextLine()) {
lineNumber++;
String line = scanner.nextLine();
if (line.contains(keyword)) {
System.out.println("文件:" + file.getPath() + " 行数:" + lineNumber + " 行内容:" + line);
}
}
scanner.close();
}
}
分享到:
相关推荐
在提供的代码实例中,我们看到了一个简单的阻塞队列实现,使用了`LinkedList`作为底层数据结构,并通过`synchronized`关键字来实现线程安全。`enqueue`方法用于向队列尾部添加元素,`dequeue`方法用于从队列头部移除...
java中,常用的阻塞式队列Demo。包含:ArrayBlockingQueue、LinkedQueue、PriorityBlockingQueue
阻塞队列的实现原理是基于锁机制和条件变量机制的,通过wait和notify方法来实现线程之间的同步。 阻塞队列与普通队列的不同在于,当队列是空的时候,从队列中获取元素的操作将会被阻塞,或者当队列满时,往队列里面...
实现java模拟阻塞队列的例子,该代码包括,阻塞队列实现生产者,消费者。和模拟阻塞队列实现生产者及消费者模式,帮助你更好的理解java多线程
双缓存队列的实现方法可以使用C++实现,通过使用模板类DoubleArray来实现双缓存队列。DoubleArray类中包含两个队列A和B,分别用来写入和读取数据。写入数据时,先将数据写入队列A,直到队列A满了,然后将写入请求...
支持多线程的阻塞队列,使用模板技术,可存储任意类型数据
C++11 实现的阻塞队列 C++11 中的阻塞队列是指在多线程环境下,实现生产者消费者模式的队列。阻塞队列的实现需要解决两个问题:线程安全和阻塞机制。在 C++11 中,我们可以使用 std::mutex、std::condition_...
阻塞队列(BlockingQueue)是一种特殊的队列,它支持两个附加操作:阻塞的插入方法put和阻塞的移除方法take。BlockingQueue继承了Queue接口,是Java 5中加入的。 BlockingQueue常用方法示例: 1. add(E e):添加一...
Java实现简单的阻塞队列2种方式,1使用wait(),notify();2使用countdownlatch实现
讲述线程池原理,线程池使用场景和注意事项,手动创建线程池方法,注意事项,阻塞队列的相关知识
并发-线程池和阻塞队列 并发-线程池和阻塞队列 并发-线程池和阻塞队列
这篇文章主要讲解了如何在微服务架构中使用SpringBoot整合Redis来构建一个基于Redis Stream的消息队列,以此来实现实时、高效的异步秒杀下单功能。 一、Redis消息队列的概念 Redis消息队列是指通过Redis数据结构...
Java 1.5引入的`java.util.concurrent`包提供了一些内置的阻塞队列实现,主要包括: 1. **ArrayBlockingQueue**:基于固定大小的数组实现,插入和删除操作都具有O(1)的时间复杂度。队列的公平性可以在构造时选择,...
阻塞队列实现生产者消费者模式Java开发Java经验技巧共4页.pdf.zip
在前面我们接触的队列都是非阻塞队列,比如PriorityQueue、LinkedList(LinkedList是双向链表,它实现了Dequeue接口)。 使用非阻塞队列的时候有一个很大问题是:它不会对当前线程产生阻塞,那么在面对类似...
消息分发框架,基于java阻塞队列实现,生产者消费者模型 可用于任务分发,服务器消息消息,以及网络IO 性能优化,多线程
没有网络的时候,将操作产生的本地图片(拍照,也可能是其他文件),存储起来。有网络的时候传输到文件服务器。 文件服务器只支持一个文件一个文件的传输。
运行,登录时,请用两个浏览器登录,应为有不同session,这是跟据session来判断用户的
DelayedQueue 是 Java 中的一种特殊的阻塞队列,它用于存放实现了 Delayed 接口的对象。这种队列是有序的,即队头对象的延迟到期时间最长。 DelayedQueue 能够满足我们在业务中的一些需求,如淘宝订单业务中,下单...
PI解决队列堵塞问题