多处理...在2个终端上运行2个脚本

Question

我有2个启动多个进程的脚本。现在我打开两个不同的终端并运行python start.py来启动两个脚本。我如何用一个命令或者一个脚本来实现这一点。

Start.py 1

# globals 
my_queue = multiprocessing.Manager().Queue() # queue to store our values 
stop_event = multiprocessing.Event() # flag which signals processes to stop 
my_pool = None 

def my_function(foo): 
    print("starting %s" % foo) 
    try: 
     addnews.varfoo) 
    except Exception,e: 
     print str(e) 

MAX_PROCESSES = 50 
my_pool = multiprocessing.Pool(MAX_PROCESSES) 

x = Var.objects.order_by('name').values('link') 
for t in x: 
    t = t.values()[0] 
    my_pool.apply_async(my_function, args=(t,)) 
my_pool.close() 
my_pool.join() 

Start1.py 2

# globals 
MAX_PROCESSES = 50 
my_queue = multiprocessing.Manager().Queue() # queue to store our values 
stop_event = multiprocessing.Event() # flag which signals processes to stop 
my_pool = None 

def my_function(var): 
    var.run_main(var) 
    stop_event.set() 


def var_scanner(): 
    # Since `t` could have unlimited size we'll put all `t` value in queue 
    while not stop_event.is_set(): # forever scan `values` for new items 
    y = Var.objects.order_by('foo).values('foo__foo') 
    for t in y: 
     t = t.values()[0] 
     my_queue.put(t) 

try: 
    var_scanner_process = multiprocessing.Process(target=var_scanner) 
    var_scanner_process.start() 
    my_pool = multiprocessing.Pool(MAX_PROCESSES) 

    #while not stop_event.is_set(): 
    try: # if queue isn't empty, get value from queue and create new process 
     var = my_queue.get_nowait() # getting value from queue 
     p = multiprocessing.Process(target=my_function, args=(var,)) 
     p.start() 
    except Queue.Empty: 
     print "No more items in queue" 
     time.sleep(1) 
     #stop_event.set() 

except KeyboardInterrupt as stop_test_exception: 
    print(" CTRL+C pressed. Stopping test....") 
    stop_event.set() 

Answer 1

可以在同一个终端上的后台运行的第一脚本，使用&壳改性剂。

python start.py & 
python start1.py