Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(14)  |  Call(0)  |  Derive(8)  |  Import(6)
A class that represents a thread of control.

This class can be safely subclassed in a limited fashion.

src/c/i/circus-0.10.0/circus/arbiter.py   circus(Download)
import errno
import logging
import os
from circus.fixed_threading import Thread, get_ident
import sys
class ThreadedArbiter(Thread, Arbiter):
 
    def __init__(self, *args, **kw):
        Thread.__init__(self)
        Arbiter.__init__(self, *args, **kw)

src/c/i/circus-HEAD/circus/arbiter.py   circus(Download)
import errno
import logging
import os
import gc
from circus.fixed_threading import Thread, get_ident
class ThreadedArbiter(Thread, Arbiter):
 
    def __init__(self, *args, **kw):
        Thread.__init__(self)
        Arbiter.__init__(self, *args, **kw)

src/c/i/circus-0.10.0/circus/stats/client.py   circus(Download)
class Painter(threading.Thread):
    def __init__(self, screen, watchers, h, w):
        threading.Thread.__init__(self)
        self.daemon = True
        self.screen = screen

src/c/i/circus-HEAD/circus/stats/client.py   circus(Download)
class Painter(threading.Thread):
    def __init__(self, screen, watchers, h, w):
        threading.Thread.__init__(self)
        self.daemon = True
        self.screen = screen

src/r/a/radon-HEAD/tests/testpkg/secondary.py   radon(Download)
# from circus
import errno
import logging
import os
from circus.fixed_threading import Thread, get_ident
class ThreadedArbiter(Thread, Arbiter):
 
    def __init__(self, *args, **kw):
        Thread.__init__(self)
        Arbiter.__init__(self, *args, **kw)

src/c/i/circus-HEAD/circus/tests/test_stats_collector.py   circus(Download)
import socket
import time
from collections import defaultdict
from circus.fixed_threading import Thread
 
        class Collector(Thread):
 
            def __init__(this, streamer):
                Thread.__init__(this)
                this.streamer = self.streamer

src/r/a/radon-0.5.1/tests/testpkg/secondary.py   radon(Download)
# from circus
import errno
import logging
import os
from circus.fixed_threading import Thread, get_ident
class ThreadedArbiter(Thread, Arbiter):
 
    def __init__(self, *args, **kw):
        Thread.__init__(self)
        Arbiter.__init__(self, *args, **kw)

src/c/i/circus-0.10.0/circus/tests/test_stats_collector.py   circus(Download)
import socket
import time
from collections import defaultdict
from circus.fixed_threading import Thread
 
        class Collector(Thread):
 
            def __init__(this, streamer):
                Thread.__init__(this)
                this.streamer = self.streamer