Rechercher : dans
Par :

[Python] Variable global ?

Dernière réponse le 3 jui 2008 à 14:46:12 BoBoX, le 24 jun 2008 à 18:29:36 
 Signaler ce message aux modérateurs

Bonjour,

Mon problème est que j'ai un thread et une GUI (wxPython)
Et ce thread doit mettre à jour la GUI grâce à une fonction faite pour, mais le problème c'est que si j'hérite de la classe GUI python me renvoie une erreur à l'éxecution de la fonction (variable qui n'est pas de la class ThreadReception)
Alors j'ai mit la gui dans une variable global (oui je sais c'est mal ^^) j'aimerais donc savoir si il est possible de fair autrement?
J'ai cherché sur google pendant plusieurs heures sans aucun résultats, merci de votre aide =)

Configuration: Linux
Firefox 3.0

Meilleures réponses pour « [Python] Variable global ? » dans :
[Bash] La variable d'environnement PATH VoirLa variable d'environnement PATH I. Préambule II. C'est quoi le shell ? III. Définition IV. Séance de dissection V. Ajouter un répertoire à la variable PATH VI. Et puis... I. Préambule Sous les systèmes GNU/Linux qu'on le veuille ou...
[Shell] Tester une variable numérique VoirTester une variable numérique    Préambule Dans un environnement "shell", les variables sont, par défaut, de type "chaîne de caractères". De ce fait il n'est pas possible de déclarer une variable de type "entier" (enfin, ceci n'est pas tout à...
Votre première application graphique avec Python et Glade VoirCe guide vous aidera à créer pas à pas votre première application graphique. Nous allons utiliser le langage de programme Python et l'API graphique GTK, en utilisant le logiciel Glade pour créer facilement les interfaces graphiques. C'est de la...
Télécharger Globe7 VoirGlobe7 a été conçu à ses début pour téléphoner et envoyer des SMS depuis un ordinateur. Cette fonction est restée, mais en plus, cette nouvelle version donne désormais accès à de nombreux médias. Globe7 intègre des gadgets téléphone logiciel, une...
Javascript - Les variables VoirLe concept de variable Une variable est un objet repéré par son nom, pouvant contenir des données, qui pourront être modifiées lors de l'exécution du programme. En Javascript, les noms de variables peuvent être aussi long que l'on désire,...
PHP - Les variables VoirConcept de variable avec PHP Une variable est un objet repéré par son nom, pouvant contenir des données, qui pourront être modifiées lors de l'exécution du programme. Les variables en langage PHP peuvent être de trois...
PHP - Les variables d'environnement VoirNotion de variable d'environnement Les variables d'environnement sont, comme leur nom l'indique, des données stockées dans des variables permettant au programme d'avoir des informations sur son environnement. L'environnement, dans le cas du script...

1

BoBoX, le 24 jun 2008 à 18:31:11

# -*- coding: Latin-1 -*-

import wx
import socket
import os, sys, time
from threading import Thread

HOST='127.0.0.1'
PORT=1502

global frame

class GUI(wx.Frame):
def __init__(self,parent,id,title):
wx.Frame.__init__(self,parent,id,title,size=(650, 500))
self.connected=False
hbox=wx.BoxSizer(wx.HORIZONTAL)
self.text = wx.TextCtrl(self, 1000, '', size=(-1, -1), style=wx.TE_MULTILINE | wx.TE_PROCESS_ENTER)
self.text.SetFocus()
self.text.SetEditable(False)
self.display = wx.TextCtrl(self, -1, '',size=(550, 30))
buttonSend=wx.Button(self,801,"Envoyer")

hbox.Add(self.display,0)
hbox.Add(buttonSend,1,wx.EXPAND)

self.sizer=wx.BoxSizer(wx.VERTICAL)
self.sizer.Add(self.text,1,wx.EXPAND)
self.sizer.Add(hbox,0,wx.EXPAND)
self.SetSizer(self.sizer)

self.Bind(wx.EVT_BUTTON, self.SendMsg, id=801)
self.Bind(wx.EVT_KEY_UP, self.OnChar)

self.Centre()
self.Show()
self.ConnectTo()

def updatetxt(self,msg):
self.msg=msg
self.text.SetEditable(True)
self.text.AppendText('\n'+self.msg)
self.text.SetEditable(False)

def OnChar(self,event):
cle=event.GetKeyCode()
if cle == 13 :
self.SendMsg(None)

def ConnectTo(self):
self.connected=True
self.connection=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
try :
self.connection.connect((HOST,PORT))
except socket.error :
print "La connexion à échoué ",HOST," ",PORT
sys.exit()

thR=ThreadReception(self.connection)
thR.start()

def SendMsg(self,event):
if self.connected is True :
message=self.display.GetValue()
self.connection.send(message)
self.display.Clear()
else :
pass

class ThreadReception(Thread):
def __init__(self,connec):
Thread.__init__(self)
self.Terminated=False
self.connexion=connec

def run(self):
while True :
msgserver=self.connexion.recv(1024)
if msgserver=='QUIT' :
self.connexion.close()
break
frame.updatetxt(msgserver)


App=wx.App()
frame=GUI(None,-1,"Client")
App.MainLoop()

Répondre à BoBoX

2

sebsauvage, le 25 jun 2008 à 11:22:04
  • +2

Les interfaces graphiques ne sont pas thread-safe !
Deux thread ne doivent jamais essayer de modifier les interfaces graphiques en même temps.
Sinon c'est le plantage assuré.

Voilà comment j'ai procédé pour WebGobbler:
J'ai un thread pour l'interface graphique, et un autre pour le réseau (et d'autres pour les traitements d'image).

Les threads communiquent entre eux grâce à un objet Queue commun.
Dans cet objet queue les threads déposent et lisent des messages (des objets).
L'objet Queue étant thread-safe, aucun risque.

Quand le thread réseau a fini son travail ou reçoit un évènement, il dépose un message (un objet, en fait, avec toutes les infos qui vont bien) dans la Queue.
Le thread de ma GUI regarde régulièrement dans la Queue s'il y a des messages, et réagit en conséquence (mise à jour de widgets ,etc.)

Ainsi, il y a un seul thread qui accède aux widgets: Aucun risque de plantage, aucune section critique à gérer.

L'objet Queue simplifie grandement la programmation multi-threads.

Répondre à sebsauvage

3

sebsauvage, le 25 jun 2008 à 11:31:29
Répondre à sebsauvage

4

sebsauvage, le 25 jun 2008 à 11:45:57
  • +1

Pour ré-expliquer les choses autrement:

Il y a un objet Queue commun à mes différents threads.

Quand l'utilisateur clic dans l'interface graphique, le thread en charge de la GUI place un message dans la Queue. Ce message veut dire "Va me chercher trucmuche".
Le thread qui s'occupe du réseau lit ce message, fait ce qu'on lui demande, et quand il a fini il place le résultat dans la Queue.

De son côté, le thread de la GUI regarde temps en temps dans la Queue s'il y a une réponse.
Quand il a une réponse, il l'affiche en mettant à jour l'interface graphique (zone de texte).


En créant des objets message, on peut véhiculer des messages, commandes et résultats entre les différents threads.
Chaque thread peut très bien être programmé pour ne réagir qu'à certains types de messages.

Répondre à sebsauvage

5

BoBoXx, le 25 jun 2008 à 18:20:57

Merci sebsauvage ! grâce à tes explications je vais enfin pouvoir progresser. :D
Mais si je fait une verification tout les temps et temps la GUI va ce bloqué non ?
Ah moin que je puisse mettre une fonction Thread dans la classe GUI.
Je vais essayer de suite :p

Répondre à BoBoXx

6

sebsauvage, le 25 jun 2008 à 20:49:32

Mais si je fait une verification tout les temps et temps la GUI va ce bloqué non ?

Non, on peut ruser.
Tkinter permet de déclencher l'appel d'une méthode après un délai donné.
Par exemple, dans ton IHM:
self.timerCollectorsStatus = self._parent.after(250, self._updateCollectorStatus)

La méthode self._updateCollectorStatus sera appelée dans 250 ms (environ, si rien n'occupe la GUI).
Dans la méthode self._updateCollectorStatus, on lit la queue pour un éventuel message, on fait les traitements qui vont bien (mise à jour des widgets), puis on ré-arme le timer (même instruction).

On peut ainsi demander à l'interface graphique de faire des vérifications régulièrement.

La lecture de l'objet Queue peut être (au choix) bloquant ou non.
En l'utilisant en non-bloquant, il rend la main immédiatement si aucun objet n'est disponible dans la queue.

Répondre à sebsauvage

7

BoBoXx, le 27 jun 2008 à 20:14:27

Voila j'ai fait ce que tu ma dit et ça fonctionne à merveille =)
reste plus qu' a régler le problème de l'encode lors du message.send(message) (ça je sais fair ^^)
Par contre j'ai un autre problème si je lance le client il va se connecté automatiquement mais lorsque je kill le processus le serveur rentre dans une boucle infinie et je suis obligé de le kill à son tour

Répondre à BoBoXx

8

sebsauvage, le 27 jun 2008 à 22:29:47

Je suis content que ça marche :-))

Sur ton serveur tu as plusieurs threads ?
Dans ce cas, il faut absolument que lors de la fermeture de l'application, le thread principale envoie un message aux autres threads leur demandant de mourir.

Même chose dans l'interface graphique, sinon ton interface graphique ne fermera jamais, ou bien fermera mais le processus restera en mémoire (car il y a encore un thread vivant).

C'est un des inconvenients de Python: le thread principal ne peut pas tuer les autres threads. Il faut qu'ils meurent tout seul ou qu'on leur demande de mourir (avec un message spécial).

Si ton serveur est en train de recevoir des données et que le client est killé, il est possible qu'il attende indéfiniment des données.
Dans ce cas, il faut faire un timeout sur le revc (ou tout autre méthode) et le thread gérant ce client doit décider de mourir s'il n'a pas reçu de données depuis x temps.

Note que pour un client serveur, je déconseille fortement d'utiliser directement les sockets, car ça pose divers problème (comment détecter qu'un client est mort, comment savoir si la réception des données est terminée, etc.).

On peut très utiliser, au lieu d'utiliser les sockets bruts, utiliser tout simplement HTTP.
C'est très efficace et facile à programmer (Python est fourni avec des serveurs et clients HTTP).

On peut aussi faire du XML-RPC, très sympa aussi (tu appelle juste une méthode sur un objet, et la méthode est automatiquement exécutée sur le serveur distant.)

Répondre à sebsauvage

9

BoBoXx, le 28 jun 2008 à 14:17:38

Non sur mon serveur je n'ai qu'un thread et j'ai mit des message pour que les threads s'arrete.

CLIENT

def OnDeco(self):
		self.thR.stop()
		self.connection.close()
		self.thR.join()
		self.thR=None
		self.updatetxt("Vous êtes maintenant déconnecté")
		self.connected=False

def on_timer(self,event):
		try :
			msg=msgStock.get_nowait()
			if msg == 'QUIT' :
				self.OnDeco()
			elif msg == 'EXIT' :
				try :
					self.OnDeco()
				except : pass
				self.Destroy()
			else :
				self.updatetxt(msg)
		except :
			pass


Et pour le serveur :

class ThreadClient(Thread):
	def __init__(self,connexion):
		Thread.__init__(self)
		self.connexion=connexion
		
	def run(self):
		nom=self.getName()
		while 1 :
			msgclient=self.connexion.recv(1024)
			if msgclient == 'QUIT' :
				for i in nbrclient :
					nbrclient[i].send(msgclient)
				break
			else :
				print nom,msgclient
				for i in nbrclient :
					nbrclient[i].send(msgclient)
		self.connexion.close()
		del nbrclient[nom]
		print "Client %s déconnecté" %(nom)


Voila c'est ça que je comprend pas en faite ^^ Ca fonctionne bien si depuis le client j'envoie la commande 'QUIT' alors les threads s'arrete des 2 cotés mais si je le kill sauvagement bah ... ^^
J'ai vais essayer de mettre un timeout =)

Sinon bah je le ferais en http mais le problème c'est que je ne sait pas véhiculer des messages à travers celui-ci.
J'ai juste réussi a faire un petit serveur Http en LAN pour transferer des données sur 2 OS différent

Répondre à BoBoXx

10

sebsauvage, le 29 jun 2008 à 00:31:38

HTTP ou XML-RPC sont très pratique.

Répondre à sebsauvage

11

pkmaide, le 30 jun 2008 à 00:15:22

Comment a tu fait pour installer python car chez moi sa ne marche pas.aide moi stp.

Répondre à pkmaide

12

BoBoXx, le 30 jun 2008 à 06:07:13

Polue pas mon sujet ...

Répondre à BoBoXx

13

sebsauvage, le 30 jun 2008 à 09:19:37

Pour en revenir à XML-RPC, j'ai trouvé une bonne page qui explique ça:
http://www-128.ibm.com/developerworks/library/ws-pyth10.html­

Cette page comporte un exemple tout simple: Le client demande le calendrier d'un mois précis, et le serveur lui envoie:

Le serveur:

import calendar, SimpleXMLRPCServer

class Calendar:
    def getMonth(self, year, month):
        return calendar.month(year, month)
    def getYear(self, year):
        return calendar.calendar(year)

calendar_object = Calendar()
server = SimpleXMLRPCServer.SimpleXMLRPCServer(("localhost", 8888))
server.register_instance(calendar_object)
print "Listening on port 8888"
server.serve_forever()


Et le cilent:

import xmlrpclib
server = xmlrpclib.ServerProxy("http://localhost:8888")
month = server.getMonth(2002, 8)
print month


Ce qui est remarquable, c'est la simplicité coté client: On déclare juste un serveur et on appelle une fonction sur le serveur.
Cela simplifie grandement les choses.

Répondre à sebsauvage

14

sebsauvage, le 30 jun 2008 à 10:18:51

Tiens tant qu'on y est, j'ai mis un exemple encore plus simple de client/serveur XML-RPC sur mon site:
http://sebsauvage.net/python/snyppets/index.html#xmlrpc

Répondre à sebsauvage

15

BoBoXx, le 3 jui 2008 à 13:09:28

Voila j'ai fait un serveur xml-rpc selon les exemples.
Je dois dir que je suis trés étonné de la longueur du code ^^

# -*- coding: Latin-1 -*-

import SimpleXMLRPCServer

class ServeurChat():
	def sendmessage(self,msg):
		print msg
		self.message=msg
		
	def rmessage(self):
		return self.message
		self.message='NONE-MSG'

chat_objet=ServeurChat()
server = SimpleXMLRPCServer.SimpleXMLRPCServer(("localhost", 8888))
server.register_instance(chat_objet)

print "Listening on port 8888"
server.serve_forever()


le problème se situe du coté client après

Répondre à BoBoXx

16

sebsauvage, le 3 jui 2008 à 13:15:10

je suis trés étonné de la longueur du code

Sympa, hein ? :-)



le problème se situe du coté client après

Des soucis ? Des message d'erreur ?

Répondre à sebsauvage

17

BoBoXx, le 3 jui 2008 à 14:06:52

Oui, dans le client j'ai un thread qui appelle la fonction rmessage() régulierement (plusieurs fois par seconde) et le problème c'est qu'il update à chaque fois mon widget text même en essayant de mettre des protections.
Je suis un peu perdue la, si jamais ta une solution :)

class ThreadReception(Thread):
	def __init__(self,connec):
		Thread.__init__(self)
		self.Terminated=False
		self.connexion=connec
		self.MSG=None
		
	def run(self):
		while not self.Terminated :
			try :
				msgserver=self.connexion.rmessage()
				if self.MSG == msgserver :
					pass
				else : 
					msgStock.put_nowait(msgserver)
					print msgserver
					self.MSG=msgserver
			except :
				pass
			
	def stop(self):
		self.Terminated=True

Répondre à BoBoXx

18

BoBoXx, le 3 jui 2008 à 14:22:57

J'ai trouvé la solution ! =)
j'ai rajouter un del

def rmessage(self):
		return self.message
		del self.message

et voila sa ne bug plus :)

Répondre à BoBoXx

19

 sebsauvage, le 3 jui 2008 à 14:46:12

Content que ça marche :-))

Répondre à sebsauvage
Collection CommentÇaMarche.net