Gammon Forum

import threading

#thread class
class ThreadTest(threading.Thread):        
    
    def __init__(self):
        threading.Thread.__init__(self)
        
    def run(self):
        self.sendHi()

    def sendHi(self):
        world.Note('hi')

#alias
def testIt(thename, theoutput, wildcards):
    world.Note("testIt called")
    t = ThreadTest()
    try:
        t.start()
    except:
        world.Note("Unexpected error:", sys.exc_info()[0])
        raise

testIt called
hi

import subprocess, time
from threading import Lock, Thread, enumerate as tenum

global_lock = Lock()

def now():
    with global_lock:
        return time.time()

def note( *args ):
    with global_lock:
        s = "".join( [ str( x ) for x in args ] )
        world.Note( s )

def t():
    for i in range( 50 ):
        note( "It's now ", now(), " since epoch" )
        time.sleep( 2 )

note( tenum(), " ", now() )

t = Thread( target = t )
t.start()

note( tenum(), " ", now() )

import subprocess, time

def note( *args ):
    s = "".join( [ str( x ) for x in args ] )
    world.Note( s )

p = subprocess.Popen( [ "ping", "-t", "wp.pl" ], stdout = subprocess.PIPE )
count = 0

def timer( *args ):
    global count
    count += 1
    if count >= 70:
        p.kill()
        return
    note( p.stdout.read( 10 ) )

Badanie 
wp.pl [212
.77.100.10
1] z 32 ba
jtami dany
ch:
Odpow
ied« z 212
.77.100.10
1: bajt˘w=
32 czas=34
ms TTL=248

    import sys, os

    SCRIPTS_PATH = "C:\Users\cji\Desktop\MUSHclient\python"
    sys.path.insert( 0, SCRIPTS_PATH )

    import world_wrap; reload( world_wrap )
    world_wrap.init( world )

    import trigreg
    import printer
    import constants

    # I mean THIS ugly:
    def reload_modules():
        for name, m in globals().iteritems():
            try:
                if name == "world_wrap":
                    continue
                __import__( name )
                printer.printf( "reloading %s\n" % name )
                reload( m )
            except:
                pass
    reload_modules()

class Wrapper( object ):
    def __init__( self, w ):
        self.world = w

    def __getattr__( self, name ):
        if not hasattr( self.world, name ):
            raise Exception( "No such method or attribute!" )

        attr = getattr( self.world, name )
        if not callable( attr ):
            return attr

        func = attr

        def wrap( *args, **kwargs ):
            ret = func( *args, **kwargs )
            if ret is None:
                ret = 0

            try:
                msg = smart_ret[ int( ret ) ]
            except:
                return ret

            if ret != 0:
                self.world.note( name )
                self.world.note( msg )

            return msg
        return wrap

com = None

def init( world ):
    global com
    com = Wrapper( world )

// ------------------- script file change monitoring thread -------------------------

void CMUSHclientDoc::ThreadFunc(LPVOID pParam)
{
// ...

// Create script source file monitoring thread
//
void CMUSHclientDoc::CreateMonitoringThread()
{
  KillThread (m_pThread, m_eventScriptFileChanged);

	CThreadData*	pData = new CThreadData;
	pData->m_strFilename = new char [m_strScriptFilename.GetLength () + 1];
  strcpy (pData->m_strFilename, m_strScriptFilename);
	pData->m_hWnd = Frame.GetSafeHwnd ();
	pData->m_hEvent = m_eventScriptFileChanged;
  pData->m_pDoc = (DWORD) this;
	m_eventScriptFileChanged.ResetEvent();

	m_pThread = (HANDLE) _beginthread (ThreadFunc, 0, pData);
  SetThreadPriority (m_pThread, THREAD_PRIORITY_IDLE);

	// Thread will delete data object
}