c++ - 如何在python的阻塞的函數中獲取變量值
問題描述
目前是使用C++嵌入式的python函數python函數是阻塞式的接收服務器消息直到退出監聽才會有返回值監聽中收到消息會調用python的一個回調函數,可以獲取到收到的消息所以要怎么樣來返回消息給C++
EDIT:代碼如下callback打印可以打印正確數據,問題是這里用pika庫寫的rabbitMQ 的client就是為了不用rabbitMQ的C庫現在有一種考慮就是再用C寫一個python可以調的module然后在回調函數里面調,就是感覺有點丑陋。
#!/usr/bin/env pythonimport pikaimport sysmessage = ''def callback(ch, method, properties, body): message = body print(method.routing_key) return message def consume(): connection = pika.BlockingConnection(pika.ConnectionParameters(host=’localhost’)) channel = connection.channel() result = channel.queue_declare(exclusive=True) queue_name = result.method.queue channel.queue_bind(exchange=’normalEx’, routing_key=’remote’, queue=queue_name) print(’ [*] Waiting for logs. To exit press CTRL+C’) channel.basic_consume(callback, queue=queue_name, no_ack=True) channel.start_consuming()
問題解答
回答1:處于堵塞的函數, 都需要等到收到數據或者等待超時才能返回的, 如果你想要快點返回, 就采用不堵塞的方式咯,只不過這樣會比較蛋疼
相關文章:
1. javascript - JS如何取對稱范圍的隨機數?2. 數據庫 - mysql如何處理數據變化中的事務?3. java - ehcache緩存用的是虛擬機內存么?4. 關于docker下的nginx壓力測試5. java - mongodb分片集群下,count和聚合統計問題6. android - java 泛型不支持數組,那么RxJava的Map集合有什么方便的手段可以定義獲得一串共同父類集合數據呢?7. dockerfile - 我用docker build的時候出現下邊問題 麻煩幫我看一下8. 服務器端 - 采用nginx做web服務器,C++開發應用程序 出現拒絕連接請求?9. javascript - 有什么兼容性比較好的辦法來判斷瀏覽器窗口的類型?10. python - pandas按照列A和列B分組,將列C求平均數,怎樣才能生成一個列A,B,C的dataframe
