Which core am I running on?

[psaffrey]

Is there some way I can get at this information at run-time? I'd like
to use it to tag diagnostic output dumped during runs using Parallel
Python.

Peter

 

[Gerhard Häring]

Is there some way I can get at this information at run-time? I'd like
to use it to tag diagnostic output dumped during runs using Parallel
Python.

There should be a way, but not with the Python standard library. It's
also platform-specific. What are you using? Linux, MacOS X, FreeBSD,
Solaris, or maybe Windows?

-- Gerhard

 

[Gerhard Häring]

Is there some way I can get at this information at run-time? I'd like
to use it to tag diagnostic output dumped during runs using Parallel
Python.

Looks like I have answered a similar question once, btw. ;-)

http://objectmix.com/python/631346-parallel-python.html

-- Gerhard

 

[psaffrey]

Looks like I have answered a similar question once, btw. ;-)

Ah, yes - thanks. I did Google for it, but obviously didn't have the
right search term.

Cheers,

Peter

 

[psaffrey]

http://objectmix.com/python/631346-parallel-python.html

Hmm. In fact, this doesn't seem to work for pp. When I run the code
below, it says everything is running on the one core.

import pp
import random
import time
from string import lowercase

ncpus = 3

def timedCharDump(waittime, char):
time.sleep(waittime)
mycore = open("/proc/%i/stat" % os.getpid()).read().split()[39]
print "I'm doing stuff!", mycore, char
return char

job_server = pp.Server(ncpus, ppservers=())

jobdetails = [ (random.random(), letter) for letter in lowercase ]

jobs = [ job_server.submit(timedCharDump,(jinput1, jinput2), (),
("os", "time",)) for jinput1, jinput2 in jobdetails ]

for job in jobs:
print job()


Peter

 

[Gerhard Häring]

http://objectmix.com/python/631346-parallel-python.html

Hmm. In fact, this doesn't seem to work for pp. When I run the code
below, it says everything is running on the one core.

import pp
import random
import time
from string import lowercase

ncpus = 3

def timedCharDump(waittime, char):
time.sleep(waittime)
mycore = open("/proc/%i/stat" % os.getpid()).read().split()[39]
print "I'm doing stuff!", mycore, char
return char

job_server = pp.Server(ncpus, ppservers=())

jobdetails = [ (random.random(), letter) for letter in lowercase ]

jobs = [ job_server.submit(timedCharDump,(jinput1, jinput2), (),
("os", "time",)) for jinput1, jinput2 in jobdetails ]

for job in jobs:
print job()

Quick look again found this:

http://brokestream.com/procstat.html

I guess I counted wrong and it's actually column 38, not 39.

-- Gerhard