小编Shw*_*til的帖子

您好我在java程序中使用MPJ库进行Pagerank算法.我编译它

javac -cp .:$MPJ_HOME/lib/mpj.jar MpiPageRank.java

并运行

mpjrun.sh -np 2 MpiPageRank

-np进程数在哪里

现在我必须找到它的pid

ps -ef|grep java

喜欢

mpjrun.sh -np 2 MpiPageRank & sleep 2
ps -ef | grep java

我明白了

pnewaska 27866 27837 99 21:28 pts/45   00:00:09 java -cp /u/pnewaska/mpj-v0_38/lib/smpdev.jar:/u/pnewaska/mpj-v0_38/lib/xdev.jar:/u/pnewaska/mpj-v0_38/lib/mpjbuf.jar:/u/pnewaska/mpj-v0_38/lib/loader2.jar:/u/pnewaska/mpj-v0_38/lib/starter.jar:/u/pnewaska/mpj-v0_38/lib/mpiExp.jar runtime.starter.MulticoreStarter /nfs/nfs1/home/pnewaska/DistributedSystems/Project3 10 smpdev useLocalLoader EMPTY MpiPageRank -i input.500k0 -n 10 -o

现在我想MpiPageRank从只有1个linux comman中提取它的pid即27866.我怎么做 ？

我使用pika库使用rabbitmctl.我使用以下代码创建一个Producer

#!/usr/bin/env python
import pika
import time
import json
import datetime


connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()



channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    #print " current time: %s "  % (str(int((time.time())*1000)))

    print body

channel.basic_consume(callback,
                      queue='hello',
                      no_ack=True)


channel.start_consuming()

由于我每次创建一个现有队列(如果没有创建队列,则覆盖队列的创建)队列因此而被破坏.现在我想删除队列.我这样做吗？