标签: blocking

在Perl脚本中,我正在编写我遇到的问题是我阻止INT和QUIT发出信号,在反引号中执行一个进程,然后取消阻塞INT和QUIT信号.我想阻止一个INT或一个人QUIT到达子进程并将其杀死.

该脚本在代码中的正确位置处成功阻塞和解除阻塞,但是,它不会延迟信号并执行我在阻塞模式下配置的处理程序,正如许多引用所说的那样.我知道它是解锁的,因为我可以SIGINT在阻塞或解除阻塞命令之前或之后发送它并且它受到尊重.

操作系统:Linux 2.6.30 Perl版本:5.8.8

代码片段:

#!/usr/local/bin/perl

use POSIX qw(:signal_h);

$SIG{'INT'} = 'gracefulExit';
sub gracefulExit { print "Caught Signal = GOOD\n"; exit; }

print "Recieving a SIGINT works here\n";
sleep 5;
my $sigset = POSIX::SigSet->new;
my $blockset = POSIX::SigSet->new(SIGINT);
sigprocmask(SIG_BLOCK, $blockset, $sigset) or die "dying at block...\n";
print "Recieving a SIGINT doesn't work here [GOOD!] and is NOT delayed [WHY!?].\n";
`/bin/sleep 5`;
sigprocmask(SIG_UNBLOCK, $blockset) or die …

我有一个Python应用程序,简而言之,从远程服务器接收数据,处理它,响应服务器,偶尔将处理后的数据保存到磁盘.我遇到的问题是要写入大量数据,并且保存过程可能需要超过半分钟.这显然是一种阻塞操作,因此在此期间网络IO会停止.我希望能够在后台进行保存操作,可以这么说,以便应用程序可以合理地快速地继续与服务器通信.

我知道,我也许需要某种线程模块来实现这一点,但我不能告诉区别是什么之间thread,threading,multiprocessing和各种其他选项.有人知道我在找什么吗？

我有这个ActionListener在EDT中被调用.我的plot()函数计算量很大,很容易花费五秒钟.它使GUI按预期挂起.我添加了SwingUtilities.invokeLater代码,它仍然挂起.由于我正在为我的升沉计算产生一个单独的线程,GUI不应该响应吗？

final ActionListener applyListener = new ActionListener() 
        {
            @CommitingFunction
            public void actionPerformed(ActionEvent arg0) 
            {
                /*Don't do plotting in the EDT :)*/
                SwingUtilities.invokeLater(new Runnable() 
                {
                    public void run() 
                    {
                        plot();
                    }
                });
            }
        };

我正在使用XMPP,我有一个消息回调,它会在发送每条消息时被激活.我的目标是将消息到达的数据发送到回调中的API,并根据响应使用XMPP客户端发回一些内容.

1. 用户类型消息(浏览器聊天客户端)
2. 消息通过XMPP到达服务器
3. 消息将发送到API
4. 收到回复
5. 响应被发送回聊天客户端.

我的代码如下

admin_muc_client.activate_message_callbacks do |m|            
  sender    = m.from.resource
  room_slug = m.from.node
  message   = m.body                  

  r = HTTParty.get('http://example.com/api/v1/query?msg=message')
  Rails.logger.debug(r.inspect)
  admin_muc_client.send_message("Message #{r.body}") if m.from.resource != 'admin'
end

我担心的是,由于回调是偶然的,并且对API的请求将是阻塞调用,这可能成为整个应用程序的瓶颈.我更喜欢使用像AJAX这样的Javascript来激活请求,当响应可用时发送数据.我怎么能在Ruby中实现它？

我查看了delayed_job和backgroundrb,它们看起来像火灾和忘记操作的工具.我需要一些能够以异步方式使用响应激活回调的东西.

我真的很感激如何实现我想要的异步行为的一些帮助.我也熟悉像RabbitMQ这样的消息队列,我觉得这会增加很多复杂性.

我正在尝试设置一个Ruby脚本,该脚本从循环中的命名管道读取,阻塞直到管道中的输入可用.

我有一个进程,定期将调试事件放入命名管道:

# Open the logging pipe
log = File.open("log_pipe", "w+") #'log_pipe' created in shell using mkfifo
...
# An interesting event happens
log.puts "Interesting event #4291 occurred"
log.flush
...

然后我想要一个单独的进程,它将从此管道中读取并在事件发生时将事件打印到控制台.我试过使用这样的代码:

input = File.open("log_pipe", "r+") 
while true
  puts input.gets  #I expect this to block and wait for input
end
# Kill loop with ctrl+c when done

我希望input.gets阻止,耐心等待,直到新的输入到达fifo; 但它会立即nil再次读取和循环,滚动控制台窗口的顶部.

我试过两件事:

1. 我用"r"和"r +"打开了输入fifo - 我有同样的问题;

2. 我试图确定我的写作过程是否正在发送EOF(我听说过它会导致读取FIFO关闭) - AFAIK它不是.

一些背景:

如果它有帮助,这里是我正在尝试做的"大图"视图:

我正在开发一款运行在基于Ruby的游戏引擎RGSS中的游戏.由于它没有很好的集成调试,我想在游戏运行时设置实时日志 - 当游戏中发生事件时,我希望消息显示在侧面的控制台窗口中.我可以使用类似于上面的编写器代码的代码将Ruby游戏代码中的事件发送到命名管道; 我现在正在尝试设置一个单独的进程,该进程将等待事件显示在管道中并在控制台到达时显示它们.我甚至不确定我需要Ruby来做这件事,但这是我能想到的第一个解决方案.

请注意,我正在使用mkfifocygwin,我碰巧安装了它; 我想知道这可能是我麻烦的根源. …

需要类似java的东西LinkedBlockingQueue.

感兴趣的方法:messageQueue.poll(120000, TimeUnit.MILLISECONDS); 意思是..获取项目..如果在X单位时间你仍然没有项目...返回null

那+我必须是FIFO

一些谷歌搜索后(但还没有测试):我发现ConcurrentQueue(有FIFO行为),BlockingCollection(FiFO或没有FIFO？)

我正在为我的客户端和服务器使用阻塞TCP套接字.每当我阅读时,我首先检查流上的数据是否可用select.我总是一次读写40个字节.虽然大多数读取需要几毫秒或更短,但有些只需要超过半秒.在我知道套接字上有可用数据之后.

我也在用 TCP_NODELAY

可能是什么原因造成的？

编辑2

我分析了发送和接收的每个数据包的时间戳,并发现只有当客户端在服务器写入下一个对象之前尝试读取对象时才会发生此延迟.例如,服务器写入对象编号x,之后客户端尝试读取对象x,然后服务器才能开始编写对象编号x + 1.这让我怀疑服务器端正在进行某种合并.

编辑

服务器正在侦听3个不同的端口.客户端逐个连接到每个端口.

有三个连接:一个连接从服务器经常向客户端发送一些数据.第二个只从客户端向服务器发送数据.第三个很少用于发送单字节数据.我正面临着第一次连接的问题.我正在检查使用select()该连接上的数据,然后当我为40字节读取时间戳时,我发现该读取大约需要半秒钟.

关于如何分析这个的任何指示都会非常有帮助

在linux上使用gcc.

rdrr_server_start(void)
{

  int rr_sd;
  int input_sd;
  int ack_sd;
  int fp_sd;

startTcpServer(&rr_sd, remote_rr_port);
  startTcpServer(&input_sd, remote_input_port);
  startTcpServer(&ack_sd, remote_ack_port);
  startTcpServer(&fp_sd, remote_fp_port);

connFD_rr = getTcpConnection(rr_sd);
  connFD_input = getTcpConnection(input_sd);
  connFD_ack= getTcpConnection(ack_sd);
  connFD_fp=getTcpConnection(fp_sd);
}

static int getTcpConnection(int sd)
{
  socklen_t l en;

  struct sockaddr_in clientAddress;
  len = sizeof(clientAddress);
  int connFD = accept(sd, (struct sockaddr*) &clientAddress, &len);
  nodelay(connFD);
  fflush(stdout);
  return connFD;
}

static void
startTcpServer(int *sd, const int port)
{ …