标签: fifo

是否存在" 无锁FIFO队列的optmistic方法"算法的 C++实现(源代码)？

在Java doc中:

[...]例外的是优先级队列,它根据提供的比较器对元素进行排序,或者元素的自然排序,以及对LIFO元素进行排序的LIFO队列(或堆栈)(后进先出)

如何实现java.util.queue使用LIFO而不是FIFO？

我想要一个类似于Array.pop()的Array方法,它表现出先入先出行为,而不是本机FILO行为.有一个简单的方法吗？

想象一下javascript控制台:

>> array = [];
>> array.push(1);
>> array.push(2);
>> array.push(3);
>> array.fifopop();
1      <-- array.pop() yields 3, instead

看一下网上的一些算法练习,我发现了一个有趣的:

如何使用LIFO实现FIFO？

我试过自己,但我最终只得到了一个解决方案:每次我们想要FIFO 的前面元素,将lifo复制到另一个lifo(不包括最后一个元素,即前面),获取前面元素并将其删除,然后复制将第二个LIFO带回第一个LIFO.

但这当然非常慢,它就是这样一个简单的循环:

for(!myfifo.empty()) {
  myfifo.pop();
}

去O(N²) ,而不是为O(n)上的标准实现FIFO的.

当然,LIFO不会做FIFO,我们通过使用"原生"FIFO和基于LIFO的假FIFO不一定具有相同的复杂性,但我认为肯定有一种比O更好的方法. (N²).有没有人对此有所了解？

提前致谢.

我想监视嵌入在knitr文件中的一些非常冗长的并行计算.

计算依赖于我编写的包,相关函数使用多核包中的mclapply 进行并行化.该函数输出进度条监视使用的稍加修改的实施的计算的进展txtProgressBar从utils的包.进度条打印到终端,并在每次mclapply迭代完成时通过fifo连接进行更新.

当从文件中获取或直接调用函数时,这种方法很好,但是我发现无法在knitr中使用它.我已经尝试了相关的块选项,我可以将消息和警告重定向到终端,但不是进度条.有人可以帮忙吗？

很抱歉没有提供最小的工作示例,但我不知道如何在此设置中制作一个.

从Amazon SQS FAQ页面:

Amazon SQS不保证对Amazon SQS队列中的消息进行FIFO访问,主要是因为Amazon SQS的分布式特性.如果您需要特定的消息排序,则应设计应用程序来处理它.

我的问题是 - 如何以这种方式设计应用程序？

这基本上是一个库存项目,分别通过购买和销售跟踪项目的"库存"和"库存".

库存系统遵循FIFO方法(首先购买的物品总是先售出).例如:

如果我们在1月,2月和3月购买了商品A当客户到来时,我们只在1月份商品结束时赠送1月份购买的商品,我们开始赠送2月商品等等

所以我必须在这里显示我手中的总库存和拆分,以便我可以看到产生的总成本.

实际表格数据:

我需要获得的结果集:

我的客户坚持认为我不应该使用Cursor,那么还有其他方法吗？

我有两个bash脚本.一个脚本写入fifo.第二个从fifo读取,但在第一个结束后写入.

但有些东西不起作用.我不明白问题出在哪里.这里的代码.

第一个脚本是(作者):

#!/bin/bash

fifo_name="myfifo";

# Se non esiste, crea la fifo;
[ -p $fifo_name ] || mkfifo $fifo_name;

exec 3<> $fifo_name;

echo "foo" > $fifo_name;
echo "bar" > $fifo_name;

第二个脚本是(读者):

#!/bin/bash

fifo_name="myfifo";

while true
do
    if read line <$fifo_name; then
       # if [[ "$line" == 'ar' ]]; then
        #    break
        #fi
        echo $line
    fi
done

有人可以帮我吗？谢谢

我真的很抱歉这么简单的问题.我只是想确保我正确理解FIFO缓存模型,并希望有人能帮助我:)如果缓存已满,LRU缓存将删除最近访问过的条目.如果缓存需要可用空间,则FIFO删除先前添加的条目(？),如果缓存需要空闲空间(例如,如果'a' - 'v' - 'f' - 'k'是缓存中的条目,'a'是最早的如果条目需要空闲空间,则缓存将删除'a'.

我对吗？

我的意思是POST一个标准的文件上传表单.在这种情况下,常用命令行包含此开关:

-F "Filedata=@filename.zip"

但是,当我尝试提供由linux命令"mkfifo"制作的命名管道时,例如."mkfifo filename.zip",我总是在生产者方面得到一条错误信息:

curl: (23) Failed writing body (1856 != 16384)

并且在fifo的消费者侧也出现了一些错误消息.我在生产者一方用另一个卷曲命令喂了我的fifo,例如:

 curl http://example.com/archive.zip > filename.zip

在消费者方面:

curl http://example.com/fileupload.php -F "file=@filename.zip"

当我在fifo的消费者端传递Content-Length HTTP标头时,我在生产者端没有收到错误消息,但是消费者(上传)端仍然出现错误消息,上传失败.

 curl http://example.com/fileupload.php -F "file=@filename.zip" -H "Content-Length: 393594678"

我也试过提供cURL文件上传一个非命名管道,导致cURL从stdin读取数据(标记为@ - ),如:

   curl -# http://example.com/archive.zip | curl -# http://example.com/fileupload.php -F "file=@-"

在这种情况下上传成功,但下载和上传进度不同步,我可以看到太单独的hashmark进度指示器,一个用于下载,一个用于上载,而是连续而不是同时运行.在该远程文件的顶部始终命名为" - ",但这对我来说不是问题,可以稍后重命名.

进一步注意:我在Ruby命令行IRB/Pry会话中尝试了上述内容,我注意到当我使用Ruby命令"system"来调用管道构造时:

system %Q{curl -# http://example.com/archive.zip | curl -# http://example.com/fileupload.php -F "file=@-"}

在这种情况下我只能看到一个散列标记进度指示器,所以我认为管道工作应该是这样,但我可以在第二种情况下看到两个连续的散列标记进度指示器,如下所示:

%x{curl -# http://example.com/archive.zip | curl -# http://example.com/fileupload.php -F "file=@-"}