यह प्रश्न अपेक्षाकृत दिलचस्प लग रहा था और इससे मुझे गुप्पी/हेपी में देखने का कारण मिला, क्योंकि मैं आपको धन्यवाद देता हूं।
मैंने शून्य भाग्य के साथ अपने स्रोत को संशोधित किए बिना एक फंक्शन कॉल/प्रक्रिया की निगरानी करने के लिए हेपी प्राप्त करने के लिए लगभग 2 घंटे तक प्रयास किया।
मुझे पाइथन लाइब्रेरी resource में निर्मित अपने कार्य को पूरा करने का एक तरीका मिला। ध्यान दें कि दस्तावेज़ीकरण इंगित नहीं करता कि RU_MAXRSS मूल्य रिटर्न क्या है। एक अन्य SO उपयोगकर्ता noted कि यह केबी में था। मैक ओएसएक्स 7.3 चल रहा है और मेरे सिस्टम संसाधनों को नीचे दिए गए टेस्ट कोड के दौरान चढ़ते हुए, मेरा मानना है कि लौटाए गए मान बाइट में नहीं हैं, केबीईटीएस नहीं।
लाइब्रेरी कॉल की निगरानी के लिए resource लाइब्रेरी का उपयोग करने के तरीके पर एक 10000 फीट दृश्य था कि फ़ंक्शन को एक अलग (मॉनिटर-सक्षम) थ्रेड में लॉन्च करना था और उस प्रक्रिया के लिए मुख्य संसाधन में सिस्टम संसाधनों को ट्रैक करना था। नीचे मेरे पास दो फाइलें हैं जिन्हें आपको परीक्षण करने के लिए चलाने की आवश्यकता होगी।
लाइब्रेरी संसाधन मॉनिटर - whatever_you_want.py
import resource
import time
from stoppable_thread import StoppableThread
class MyLibrarySniffingClass(StoppableThread):
def __init__(self, target_lib_call, arg1, arg2):
super(MyLibrarySniffingClass, self).__init__()
self.target_function = target_lib_call
self.arg1 = arg1
self.arg2 = arg2
self.results = None
def startup(self):
# Overload the startup function
print "Calling the Target Library Function..."
def cleanup(self):
# Overload the cleanup function
print "Library Call Complete"
def mainloop(self):
# Start the library Call
self.results = self.target_function(self.arg1, self.arg2)
# Kill the thread when complete
self.stop()
def SomeLongRunningLibraryCall(arg1, arg2):
max_dict_entries = 2500
delay_per_entry = .005
some_large_dictionary = {}
dict_entry_count = 0
while(1):
time.sleep(delay_per_entry)
dict_entry_count += 1
some_large_dictionary[dict_entry_count]=range(10000)
if len(some_large_dictionary) > max_dict_entries:
break
print arg1 + " " + arg2
return "Good Bye World"
if __name__ == "__main__":
# Lib Testing Code
mythread = MyLibrarySniffingClass(SomeLongRunningLibraryCall, "Hello", "World")
mythread.start()
start_mem = resource.getrusage(resource.RUSAGE_SELF).ru_maxrss
delta_mem = 0
max_memory = 0
memory_usage_refresh = .005 # Seconds
while(1):
time.sleep(memory_usage_refresh)
delta_mem = (resource.getrusage(resource.RUSAGE_SELF).ru_maxrss) - start_mem
if delta_mem > max_memory:
max_memory = delta_mem
# Uncomment this line to see the memory usuage during run-time
# print "Memory Usage During Call: %d MB" % (delta_mem/1000000.0)
# Check to see if the library call is complete
if mythread.isShutdown():
print mythread.results
break;
print "\nMAX Memory Usage in MB: " + str(round(max_memory/1000.0, 3))
stoppable थ्रेड - stoppable_thread.py
import threading
import time
class StoppableThread(threading.Thread):
def __init__(self):
super(StoppableThread, self).__init__()
self.daemon = True
self.__monitor = threading.Event()
self.__monitor.set()
self.__has_shutdown = False
def run(self):
'''Overloads the threading.Thread.run'''
# Call the User's Startup functions
self.startup()
# Loop until the thread is stopped
while self.isRunning():
self.mainloop()
# Clean up
self.cleanup()
# Flag to the outside world that the thread has exited
# AND that the cleanup is complete
self.__has_shutdown = True
def stop(self):
self.__monitor.clear()
def isRunning(self):
return self.__monitor.isSet()
def isShutdown(self):
return self.__has_shutdown
###############################
### User Defined Functions ####
###############################
def mainloop(self):
'''
Expected to be overwritten in a subclass!!
Note that Stoppable while(1) is handled in the built in "run".
'''
pass
def startup(self):
'''Expected to be overwritten in a subclass!!'''
pass
def cleanup(self):
'''Expected to be overwritten in a subclass!!'''
pass
स्रोत
2012-04-12 05:05:13
धन्यवाद एमबी विभाजन में परिवर्तित करने के लिए! – astrofrog
@astrofrog मदद करने के लिए खुशी हुई। यह कुछ ऐसा है जो मैं भविष्य में भी लाभ उठा सकता हूं। –
मैंने इस कोड को एक गिस्ट के रूप में रखा है, इसलिए फ़ाइलों को डाउनलोड करना आसान है: https://gist.github.com/b54fafd87634f017d50d – Tom