Das deutsche Python-Forum

Code: Alles auswählen

# -*- coding: utf-8 -*-

from sqlalchemy import *
from sqlalchemy.orm import mapper
from sqlalchemy.orm import sessionmaker
import os, time, thread

class Zeiten(object):
    pass
    
engine = create_engine('sqlite:///adressen.db')
metadata = MetaData()
metadata.bind = engine

Session = sessionmaker(bind=engine)
session = Session()

tab = Table('Zeittabelle', metadata,
Column('id', Integer, primary_key = True),
Column('Zeit',Integer))
metadata.create_all()

mapper(Zeiten, tab)


def neueZeiten():
    for i in range(100):
        engine = create_engine('sqlite:///adressen.db')
        Session = sessionmaker(bind=engine)
        session = Session()

        neue_Zeit = Zeiten()
        neue_Zeit.Zeit = time.time()

        session.add(neue_Zeit)
        session.commit()
        print "Thread"

thread.start_new_thread(neueZeiten,()) 

for i in range(100):
    neue_Zeit = Zeiten()
    neue_Zeit.Zeit = time.time()

    session.add(neue_Zeit)
    session.commit()
    print 'Hauptprogramm'

Code: Alles auswählen

import Queue
from threading import Thread

SUPER_IMPORTANT = 0
NOT_SO_IMPORTANT = 1

def writer(queue):
    while True:
        priority, data = queue.get()
        ... write data somewhere ...

def super_important_stuff(queue):
    while True:
        data = ... get super important data ...
        queue.put((SUPER_IMPORTANT, data))

def not_so_important_stuff(queue):
    while True:
        data = ... get not so important data ...
        queue.put((NOT_SO_IMPORTANT, data))

def main():
    queue = Queue.PriorityQueue()
    threads = (
        [Thread(target=lambda:writer(queue))] +
        [Thread(target=lambda:super_important_stuff(queue)) for i in xrange(3)] +
        [Thread(target=lambda:not_so_important_stuff(queue)) for i in xrange(10)])
    for each in threads:
        each.start()
    ... laaaange Zeit irgendwas anderes machen, und dann irgendwann:
    for each in threads:
        each.join()

Code: Alles auswählen

def db_thread(queue):  # war: writer()
    while True:
        priority, data, result_queue = queue.get()
        if result_queue is not None:
            result = ... select *** from ---
            result_queue.put(result)
        else:
            ... write data somewhere ...

def query(db_queue, importance, *params):
    result_queue = Queue.Queue()
    db_queue.put((importance, ...select stmt..., result_queue))
    return result_queue.get()  # blockt bis das Ergebnis da ist
    
def super_important_stuff(queue):
    while True:
        data = ... get super important data ...
        queue.put((SUPER_IMPORTANT, data, None))

...

my_data = query(SUPER_IMPORTANT, queue, bla, fasel)