本文目录一览:
如何使用queue
Queue接口与List、Set同一级别,都是继承了Collection接口。LinkedList实现了Queue接 口。Queue接口窄化了对LinkedList的方法的访问权限(即在方法中的参数类型如果是Queue时,就完全只能访问Queue接口所定义的方法 了,而不能直接访问 LinkedList的非Queue的方法),以使得只有恰当的方法才可以使用。BlockingQueue 继承了Queue接口。
队列是一种数据结构.它有两个基本操作:在队列尾部加人一个元素,和从队列头部移除一个元素就是说,队列以一种先进先出的方式管理数据,如果你试图向一个 已经满了的阻塞队列中添加一个元素或者是从一个空的阻塞队列中移除一个元索,将导致线程阻塞.在多线程进行合作时,阻塞队列是很有用的工具。工作者线程可 以定期地把中间结果存到阻塞队列中而其他工作者线线程把中间结果取出并在将来修改它们。队列会自动平衡负载。如果第一个线程集运行得比第二个慢,则第二个 线程集在等待结果时就会阻塞。如果第一个线程集运行得快,那么它将等待第二个线程集赶上来。下表显示了jdk1.5中的阻塞队列的操作:
add 增加一个元索 如果队列已满,则抛出一个IIIegaISlabEepeplian异常
remove 移除并返回队列头部的元素 如果队列为空,则抛出一个NoSuchElementException异常
element 返回队列头部的元素 如果队列为空,则抛出一个NoSuchElementException异常
offer 添加一个元素并返回true 如果队列已满,则返回false
poll 移除并返问队列头部的元素 如果队列为空,则返回null
peek 返回队列头部的元素 如果队列为空,则返回null
put 添加一个元素 如果队列满,则阻塞
take 移除并返回队列头部的元素 如果队列为空,则阻塞
remove、element、offer 、poll、peek 其实是属于Queue接口。
阻塞队列的操作可以根据它们的响应方式分为以下三类:aad、removee和element操作在你试图为一个已满的队列增加元素或从空队列取得元素时 抛出异常。当然,在多线程程序中,队列在任何时间都可能变成满的或空的,所以你可能想使用offer、poll、peek方法。这些方法在无法完成任务时 只是给出一个出错示而不会抛出异常。
注意:poll和peek方法出错进返回null。因此,向队列中插入null值是不合法的。
还有带超时的offer和poll方法变种,例如,下面的调用:
boolean success = q.offer(x,100,TimeUnit.MILLISECONDS);
尝试在100毫秒内向队列尾部插入一个元素。如果成功,立即返回true;否则,当到达超时进,返回false。同样地,调用:
Object head = q.poll(100, TimeUnit.MILLISECONDS);
如果在100毫秒内成功地移除了队列头元素,则立即返回头元素;否则在到达超时时,返回null。
最后,我们有阻塞操作put和take。put方法在队列满时阻塞,take方法在队列空时阻塞。
java.ulil.concurrent包提供了阻塞队列的4个变种。默认情况下,LinkedBlockingQueue的容量是没有上限的(说的不准确,在不指定时容量为Integer.MAX_VALUE,不要然的话在put时怎么会受阻呢),但是也可以选择指定其最大容量,它是基于链表的队列,此队列按 FIFO(先进先出)排序元素。
ArrayBlockingQueue在构造时需要指定容量, 并可以选择是否需要公平性,如果公平参数被设置true,等待时间最长的线程会优先得到处理(其实就是通过将ReentrantLock设置为true来 达到这种公平性的:即等待时间最长的线程会先操作)。通常,公平性会使你在性能上付出代价,只有在的确非常需要的时候再使用它。它是基于数组的阻塞循环队 列,此队列按 FIFO(先进先出)原则对元素进行排序。
PriorityBlockingQueue是一个带优先级的 队列,而不是先进先出队列。元素按优先级顺序被移除,该队列也没有上限(看了一下源码,PriorityBlockingQueue是对 PriorityQueue的再次包装,是基于堆数据结构的,而PriorityQueue是没有容量限制的,与ArrayList一样,所以在优先阻塞 队列上put时是不会受阻的。虽然此队列逻辑上是无界的,但是由于资源被耗尽,所以试图执行添加操作可能会导致 OutOfMemoryError),但是如果队列为空,那么取元素的操作take就会阻塞,所以它的检索操作take是受阻的。另外,往入该队列中的元 素要具有比较能力。
最后,DelayQueue(基于PriorityQueue来实现的)是一个存放Delayed 元素的无界阻塞队列,只有在延迟期满时才能从中提取元素。该队列的头部是延迟期满后保存时间最长的 Delayed 元素。如果延迟都还没有期满,则队列没有头部,并且poll将返回null。当一个元素的 getDelay(TimeUnit.NANOSECONDS) 方法返回一个小于或等于零的值时,则出现期满,poll就以移除这个元素了。此队列不允许使用 null 元素。 下面是延迟接口:
Java代码
public
interface
Delayed
extends
ComparableDelayed
{
long
getDelay(TimeUnit
unit);
}
放入DelayQueue的元素还将要实现compareTo方法,DelayQueue使用这个来为元素排序。
下面的实例展示了如何使用阻塞队列来控制线程集。程序在一个目录及它的所有子目录下搜索所有文件,打印出包含指定关键字的文件列表。从下面实例可以看出,使用阻塞队列两个显著的好处就是:多线程操作共同的队列时不需要额外的同步,另外就是队列会自动平衡负载,即那边(生产与消费两边)处理快了就会被阻塞掉,从而减少两边的处理速度差距。下面是具体实现:
Java代码
public
class
BlockingQueueTest
{
public
static
void
main(String[]
args)
{
Scanner
in
=
new
Scanner(System.in);
System.out.print("Enter
base
directory
(e.g.
/usr/local/jdk5.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_THREADS
=
100;//
关键字搜索线程个数
//
基于ArrayBlockingQueue的阻塞队列
BlockingQueueFile
queue
=
new
ArrayBlockingQueueFile(
FILE_QUEUE_SIZE);
//只启动一个线程来搜索目录
FileEnumerationTask
enumerator
=
new
FileEnumerationTask(queue,
new
File(directory));
new
Thread(enumerator).start();
//启动100个线程用来在文件中搜索指定的关键字
for
(int
i
=
1;
i
=
SEARCH_THREADS;
i++)
new
Thread(new
SearchTask(queue,
keyword)).start();
}
}
class
FileEnumerationTask
implements
Runnable
{
//哑元文件对象,放在阻塞队列最后,用来标示文件已被遍历完
public
static
File
DUMMY
=
new
File("");
private
BlockingQueueFile
queue;
private
File
startingDirectory;
public
FileEnumerationTask(BlockingQueueFile
queue,
File
startingDirectory)
{
this.queue
=
queue;
this.startingDirectory
=
startingDirectory;
}
public
void
run()
{
try
{
enumerate(startingDirectory);
queue.put(DUMMY);//执行到这里说明指定的目录下文件已被遍历完
}
catch
(InterruptedException
e)
{
}
}
//
将指定目录下的所有文件以File对象的形式放入阻塞队列中
public
void
enumerate(File
directory)
throws
InterruptedException
{
File[]
files
=
directory.listFiles();
for
(File
file
:
files)
{
if
(file.isDirectory())
enumerate(file);
else
//将元素放入队尾,如果队列满,则阻塞
queue.put(file);
}
}
}
class
SearchTask
implements
Runnable
{
private
BlockingQueueFile
queue;
private
String
keyword;
public
SearchTask(BlockingQueueFile
queue,
String
keyword)
{
this.queue
=
queue;
this.keyword
=
keyword;
}
public
void
run()
{
try
{
boolean
done
=
false;
while
(!done)
{
//取出队首元素,如果队列为空,则阻塞
File
file
=
queue.take();
if
(file
==
FileEnumerationTask.DUMMY)
{
//取出来后重新放入,好让其他线程读到它时也很快的结束
queue.put(file);
done
=
true;
}
else
search(file);
}
}
catch
(IOException
e)
{
e.printStackTrace();
}
catch
(InterruptedException
e)
{
}
}
public
void
search(File
file)
throws
IOException
{
Scanner
in
=
new
Scanner(new
FileInputStream(file));
int
lineNumber
=
0;
while
(in.hasNextLine())
{
lineNumber++;
String
line
=
in.nextLine();
if
(line.contains(keyword))
System.out.printf("%s:%d:%s%n",
file.getPath(),
lineNumber,
line);
}
in.close();
}
}
求C语言源代码:从键盘输入两个矩阵,输出这两个矩阵和这两个矩阵相乘的矩阵?
写的有点烦了,不过你看的懂就可以:
#include iostream
#include vector
#include algorithm
#include stdio.h
#include string.h
using namespace std;
typedef vectorvectorint matrix;
typedef vectorint row;
void GetMatrix(matrix m)
{
row tmp;
int n;
size_t size = 0;
while(cin.peek() != '#')
{
cin.unsetf(ios::skipws);
while(cin cin.peek() != '\n')
{
while(cin.peek() == ' ')
cin.get();
if(cin.peek() == '#')
break;
cin n;
while(cin.peek() == ' ')
cin.get();
tmp.push_back(n);
}
if(cin.peek() != '#')
cin.get();
if(!cin)
{
cerr "ERROR: Invalid input characters.\n";
exit(0);
}
if(size != 0 size != tmp.size())
{
cerr "ERROR: Jagged matrix not allowed.\n";
exit(0);
}
size = tmp.size();
m.push_back(tmp);
tmp.clear();
}
cin.ignore(512, '\n');
}
void PrintMatrix(const matrix m)
{
static char num[32];
int max = *max_element(m[0].begin(), m[0].end());
int n;
for(size_t i = 1; i m.size(); ++i)
if(max (n = *max_element(m[i].begin(), m[i].end())))
max = n;
sprintf(num, "%d", max);
cout.setf(ios::left);
for(size_t i = 0; i m.size(); ++i)
{
for(size_t j = 0; j m[i].size(); ++j)
{
cout.width(strlen(num));
cout m[i][j] ' ';
}
cout '\n';
}
}
void MatrixMul(const matrix m1, const matrix m2, matrix product)
{
if(m1[0].size() != m2.size())
{
cerr "Candidate not allowed.\n";
cerr "If m1 is a m * n matrix so m2 must be a n * p matrix.\n";
exit(0);
}
for(size_t i = 0; i m1.size(); ++i)
{
product.push_back(row());
for(size_t j = 0; j m2[0].size(); ++j)
{
product[i].push_back(0);
for(size_t k = 0; k m1[0].size(); ++k)
product[i][j] += m1[i][k] * m2[k][j];
}
}
}
int main()
{
matrix m1, m2, m3;
cout "Enter matrix1:\n";
GetMatrix(m1);
cout "\nEnter matrix2:\n";
GetMatrix(m2);
MatrixMul(m1, m2, m3);
cout "\n\nmatrix 1: " m1.size() " × " m1[0].size() '\n';
PrintMatrix(m1);
cout "\n\nmatrix 2: " m2.size() " × " m2[0].size() '\n';
PrintMatrix(m2);
cout "\n\nm1 * m2: " m3.size() " × " m3[0].size() '\n';
PrintMatrix(m3);
}
黄童白叟是什么生肖动物
你好很高兴为您解答
黄童白叟是代表什么生肖
兔
童字代表兔生肖,兔天真烂漫,一世善良。属兔人性格聪颖,诚实,知书达理,处事圆滑,喜好和平,待人谦逊,宽厚仁慈信义当先。学习能力上佳,文质彬彬之人。处事得体,心思细腻,温文尔雅,善交际,伶牙俐齿。希望我的回答对您有帮助,祝你生活愉快!
怎么解决显示器驱动程序已停止响应,并且已恢复
显示器驱动程序已停止响应的解决办法:首先,点“开始”,找到“计算机”并点右键,找到“属性”打开,找到“高级系统设置”并打开,打开“高级系统设置”后,找到选项卡“高级”并打开,在“高级”选项卡中找到“性能”的选项“设置”。
进入“设置”,找到“视觉效果”的“玻璃效果”和“启用桌面组合”取消这两个显示效果,选择完成点“确定”,显示器会黑屏一会切换显示效果。
这里注意一点:当你关闭“启用桌面组合”显示效果后,那么“启用AeroPeek”也就自动关闭了,因为“启用AeroPeek”的前提就是先要启用“启用桌面组合”。
当你关闭“启用桌面组合”后,“启用AeroPeek”消失了,重新启用“启用桌面组合”才能找回“启用AeroPeek”效果。
可以先关闭“玻璃效果”看一下,如果显示的问题解决了,就不要关闭“启用桌面组合”了。毕竟关闭了“启用桌面组合”就没法用“AeroPeek”效果了。