标签: queuing

ASP.net会话请求排队

在我看来,ASP.net排队使用相同会话ID的所有请求.假设你有3页.

Default.aspx的

protected void Page_Load(object sender, EventArgs e)
{
    Session["asdf"] = "LOLZ";
}
Run Code Online (Sandbox Code Playgroud)

如果不存在,点击此页面显然会创建一个新会话.

X-AspNet-Version: 2.0.50727
Set-Cookie: ASP.NET_SessionId=ibjphuv0aiafqi453tyze345; path=/; HttpOnly
Run Code Online (Sandbox Code Playgroud)

然后你点击Hang.aspx

protected void Page_Load(object sender, EventArgs e)
{
    Thread.Sleep(10000);
}
Run Code Online (Sandbox Code Playgroud)

在你点击任何其他页面后会立即传递此会话ID,无论它是否有任何作用,我们称之为Test.aspx.

加载的顺序是这样的.

Request            Timeline
"GET /"            |*|
"GET /Hang.aspx"       |******************************************|
"GET /Test.aspx"            |**************************************|
Run Code Online (Sandbox Code Playgroud)

我想我的问题是如何禁用此功能.我知道让会话状态更可预测是有用的,但在我的情况下,长时间运行的报告页面加载会破坏用户的多任务处理能力.

asp.net session queuing blocking

26
推荐指数
1
解决办法
6685
查看次数

如何构建PHP队列系统

我不得不构建一个PHP Queue System,并发现了这篇精彩的文章 http://squirrelshaterobots.com/programming/php/building-a-queue-server-in-php-part-1-understanding-the-project,我用它来创建一个PHP队列系统,它非常容易设置和使用.

下面是queue.php的代码,从shell(puTTy或somesuch)运行.

<?PHP 

//. set this constant to false if we ever need to debug
//. the application in a terminal.
define('QUEUESERVER_FORK', true);

//////// fork into a background process ////////
if(QUEUESERVER_FORK){    
    $pid = pcntl_fork(); 
    if($pid === -1) die('error: unable to fork.');    
    else if($pid) exit(0);        
    posix_setsid();    
    sleep(1);        
    ob_start();
}

$queue = array();

//////// setup our named pipe ////////
$pipefile = '/tmp/queueserver-input';

if(file_exists($pipefile))    
    if(!unlink($pipefile))         
        die('unable to remove stale file');

umask(0);


if(!posix_mkfifo($pipefile, 0666))    
    die('unable to create named pipe'); …
Run Code Online (Sandbox Code Playgroud)

php queue daemon system queuing

10
推荐指数
1
解决办法
3万
查看次数

SQL Server是否具有类似于Oracle Streams Advanced Queuing的功能?

Oracle Streams AQ(高级队列)提供高度可扩展的数据库支持的排队功能.SQL Server(任何版本)中是否存在等效功能?

注意:我并不是简单地将表用作队列,而是使用特定的供应商提供的数据库平台增强功能.

sql-server oracle queuing advanced-queuing

7
推荐指数
1
解决办法
2096
查看次数

消耗使用核心api后,HornetQ消息仍然在队列中

我是HornetQ的新手所以请耐心等待.我先告诉你我的要求:

我需要一个消息排队中间件,它可以在不同进程之间传递大小约1k的消息,具有低延迟和持久性(即它应该能够在系统崩溃中存活).我将有多个进程写入相同的队列,同样多个进程从同一队列中读取.

为此,我选择了HornetQ,因为它具有持久性消息传递的最佳评级.

我目前使用Hornetq v2.2.2Final作为独立服务器.
我能够使用核心api (ClientSession)成功创建持久/非持久队列,并成功将消息发布到队列(ClientProducer).
同样,我可以使用核心API (ClientConsumer)从队列中读取消息.

在此之后问题出现时,客户端已读取消息,消息仍保留在队列中,即队列中的消息数保持不变.也许我弄错了但是我的印象是,一旦消息被消耗 (读取+确认),它就会从队列中删除.但这种情况在我的情况下并没有发生,并且正在反复阅读相同的消息再次.

此外,我想告诉我,我已经尝试使用非持久性队列和非持久性消息.但问题仍然存在.

我正在使用的生产者代码:

public class HQProducer implements Runnable {

    private ClientProducer producer;
    private boolean killme;
    private ClientSession session;
    private boolean durableMsg;

    public HQProducer(String host, int port, String address, String queueName,
            boolean deleteQ, boolean durable, boolean durableMsg, int pRate) {
        this.durableMsg = durableMsg;
        try {
            HashMap map = new HashMap();
            map.put("host", host);
            map.put("port", port);

            TransportConfiguration config = new …
Run Code Online (Sandbox Code Playgroud)

java queuing producer-consumer persistent-storage hornetq

7
推荐指数
1
解决办法
8121
查看次数

R作业排队/工作负载管理

我花了一些时间在Google上寻找R的排队/负载均衡器包.

我想要实现的目标:

  • 从远程前端执行多个独立的R函数独立
  • 利用2个双核服务器作为R后端

知道:

  • 每个功能通常在10到30秒内处理
  • 平均每5分钟(但它可以同时)将一组8-15个要执行的函数发送到后端(排队等待处理:先进先出).5分钟是平均值,也可以同时发送几组
  • 2x2 R实例已经运行,加载了所需的包,它们总是相同的,所以不需要一直重新加载它们
  • 输入的数据输入量非常低:最大50k

这里没有代码并行化主题(雪,降雪foreach,condor和其他传统的集群解决方案)

你知道一个专为R设计的好包装/工具吗?

非常感谢 !

r queuing workload job-scheduling

6
推荐指数
1
解决办法
639
查看次数

交易排队/出队

我需要以可靠/事务方式为外部系统排队事件和任务.使用像MSMQ或ActiveMQ这样的东西看起来非常诱人,但事务部分变得复杂(MSDTC等).

我们可以使用数据库(SQL Server 2005 +,Oracle 9+)并实现更简单的事务支持,但排队部分变得更加丑陋.

两条路线看起来都不那么好,并且充满了讨厌的陷阱和边缘情况.

有人可以在这个问题上提供一些实用指导吗?

想一想:E/C/A或计划任务引擎每隔一段时间就会唤醒并查看此时是否有任何需要运行的计划任务(即下一个运行日期已过,但到期日期尚未到期到达).

architecture queuing transactional

5
推荐指数
1
解决办法
1620
查看次数

新的linux tc排队规则创造了爆发...耗尽了知识

我想为linux内核编写一个新的tc排队规则.目标是排队等等.十个数据包,然后将它们全部发送出去(我知道,这对网络来说并不是一件好事,但我想对此进行一些研究).

那么,已经做了什么:我有一个新的sched-module(enqueue,dequeue函数等)的框架,它也正确编译并正确工作(一个数据包排队,一个数据包发送 - 没什么特别的).我正在使用与正在运行的内核相同的源代码在ubuntu maverick上编译它,并将我的模块放在Makefile和Kconfig中.

我想,每次调用enqueue函数,之后qdisc_restart(在sch_generic.c中)调用dequeue函数 - 并且只发送一个数据包.

我的问题是:如何从我的模块向网络接口发送多个数据包,就像我收集的那样.10包现在我想把它们全部发送出去?

我尝试使用与qdisc_restart(和锁定机制)相同的参数调用sch_direct_xmit函数(来自sch_generic.c) - 但是,然后,我的模块的编译失败:未知符号sch_direct_xmit(但greping/proc/kallsyms为此给了我结果).有什么想法,那有什么不对?如果需要一些代码,请告诉我(我在sched_generic.c中包含了相同的.h)

BR Christoph

linux queuing linux-kernel

5
推荐指数
1
解决办法
365
查看次数

不要排队fadeTo(),fadeIn()/ fadeOut()

我有以下动画:

$('#id').animate({'margin-top': 100, 'margin-left': 100}, {queue: false, duration: 1000});
$('#id2').fadeTo(1000, 1);
Run Code Online (Sandbox Code Playgroud)

这似乎是排队,我怎样才能确保fadeTo()不排队?

jquery queuing jquery-animate

3
推荐指数
1
解决办法
8874
查看次数