1

我需要在我的项目中使用 beanstalked。所以我下载了 1.1 版本。我将 beanstalkc 用于 python 客户端。一个简单的生产者-消费者模型。

制片人:

       import beanstalkc
       beanstalk = beanstalkc.Connection('localhost')
       beanstalk.use('foo')
       beanstalk.put('hello')
       beanstalk.put('world')

消费者:

      import beanstalkc
      beanstalk.use('foo')
      beanstalk = beanstalkc.Connection('localhost')
      job = beanstalk.reserve()

但是预约操作被阻塞了很久。有没有人遇到过这个问题?

4

0 回答 0