Cancel Async call

Version imprimable

22/10/2008, 21h48
rikidude

Cancel Async call

Bonjour,

J'ai un application client qui fait appel a une super fonction d'un service web.
Après l'appel de cette fonction, j'aimerais annuler le travail.
Alors je fait: WebService.CancelAsync(Nothing)

Le problème: Avant que le processus soit vraiment cancellé, il termine la boucle qu'il avait entammé. Tout est transparent à l'utilisateur, mais le serveur continue de travailler.

Exemple:

-Le client appel la création de tables venant d'un fichier texte
-La fonction sur le serveur entre dans une boucle while not eof
-Quand même que le client cancel le processus, le serveur execute les opération qui sont dans la boucle.

Merci beaucoup,
22/10/2008, 22h08
Sehnsucht
mettre dans ta boucle while un test
Code:

1 2 3 4 If cancel Then Exit While End If
ça te permettra de quitter ta boucle plus tôt à toi de voir comment l'intégrer au mieux à ton programme (fichier à refermer, etc...)
22/10/2008, 22h13
tomlev

Comme l'indique le nom de la fonction, elle annule le traitement de façon asynchrone. Si ça interrompait le traitement immédiatement, ce serait une fonction synchrone...
22/10/2008, 23h20
rikidude
Cancel n'existe pas dans mon webService !?
Dois-je importer quelque chose?

Merci
Citation:
Envoyé par Sehnsucht

mettre dans ta boucle while un test

Code:

1 2 3 4 If cancel Then Exit While End If

ça te permettra de quitter ta boucle plus tôt à toi de voir comment l'intégrer au mieux à ton programme (fichier à refermer, etc...)
22/10/2008, 23h55
Sehnsucht

Citation:

Envoyé par Sehnsucht

à toi de voir comment l'intégrer au mieux à ton programme
23/10/2008, 14h39
rikidude

Je ne comprend pas ce que tu veux dire.
Qu'est-ce que je dois tester pour voir si l'appel de la fonction à été annulé?

Merci
23/10/2008, 15h02
tomlev

Citation:

Envoyé par rikidude

Qu'est-ce que je dois tester pour voir si l'appel de la fonction à été annulé?

une variable (appelée cancel dans l'exemple de Sehnsucht) que tu positionnes à true dans la méthode CancelAsync
23/10/2008, 15h09
rikidude

Citation:

Envoyé par tomlev

une variable (appelée cancel dans l'exemple de Sehnsucht) que tu positionnes à true dans la méthode CancelAsync

Ou est-ce que je trouve la méthode CancelAsync? C'est possible de l'apeler à partir de l'application client, mais du côté webService je ne la trouve pas.

Merci
23/10/2008, 16h34
tomlev

ben c'est toi qui as le code, pas nous... donc on peut pas savoir où elle est

CancelAsync est un méthode du serviceWeb, ce n'est pas moi qui à inventé cela!!

Voici un exemple qui ne marche absoluement pas!

App Client:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
Public Class Form1
 
    Dim webservice As New localhost.Service
 
    Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
        Try
            AddHandler webservice.tryinCompleted, AddressOf tryinAsyncComplete
            webservice.tryinAsync()
        Catch ex As Exception
            MessageBox.Show(ex.Message)
        End Try
    End Sub
 
    Private Sub Button2_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button2.Click
        Try
            webservice.CancelAsync(Nothing)
        Catch ex As Exception
            MessageBox.Show(ex.Message)
        End Try
    End Sub
 
    Private Sub tryinAsyncComplete()
        MessageBox.Show("Opération terminé")
    End Sub
 
End Class

WebService:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
Imports System.Web
Imports System.Web.Services
Imports System.Web.Services.Protocols
Imports System.Threading
Imports System.IO
 
<WebService(Namespace:="http://tempuri.org/")> _
<WebServiceBinding(ConformsTo:=WsiProfiles.BasicProfile1_1)> _
<Global.Microsoft.VisualBasic.CompilerServices.DesignerGenerated()> _
Public Class Service
    Inherits System.Web.Services.WebService
 
    Private g_bln_cancel As Boolean
    Public Property Cancelation() As Boolean
        Get
            Cancelation = g_bln_cancel
        End Get
        Set(ByVal value As Boolean)
            g_bln_cancel = value
        End Set
    End Property
 
    Public Sub New()
        Cancelation = False
    End Sub
 
    <WebMethod()> _
    Public Function HelloWorld() As String
        Return "Hello World"
    End Function
 
    <WebMethod()> _
    Public Function tryin() As Boolean
        save1()
        save2()
 
        Return True
    End Function
 
    Private Sub save1()
        Dim l_obj_fichier As New StreamWriter("C:\save1.txt")
        For i As Integer = 0 To 10
            If Cancelation Then
                l_obj_fichier.WriteLine(i & " CANCELED")
                l_obj_fichier.Close()
                Exit Sub
            End If
            l_obj_fichier.WriteLine(i)
            Thread.Sleep(1000)
        Next
 
        l_obj_fichier.Close()
    End Sub
 
    Private Sub save2()
        Dim l_obj_fichier As New StreamWriter("C:\save2.txt")
        For i As Integer = 0 To 10
            If Cancelation Then
                l_obj_fichier.WriteLine(i & " CANCELED")
                l_obj_fichier.Close()
                Exit Sub
            End If
            l_obj_fichier.WriteLine(i)
            Thread.Sleep(1000)
        Next
 
        l_obj_fichier.Close()
    End Sub
 
    Public Overloads Sub CancelAsync(ByVal userState As Object)
        Cancelation = True
        Me.CancelAsync(userState)
    End Sub
 
End Class

Si je clique sur le bouton 2 (qui appel la méthode CancelAsync) tout de suite après avoir cliqué sur le bouton 1 (qui appel la fonction du service web), le service web me retourne l'état, mais les 2 procédure sont tout de même executé jusqu'à la fin. C'est à dire que mes 2 fichiers son créer jusqu'à la fin.

23/10/2008, 21h36
tomlev

Citation:

Envoyé par rikidude

Ou est-ce que je trouve la méthode CancelAsync?

euh... elle est dans le code que tu as posté :roll:

Citation:

Envoyé par rikidude

CancelAsync est un méthode du serviceWeb, ce n'est pas moi qui à inventé cela!!

Ben en tous cas la classe WebService n'a pas de méthode CancelAsync, donc a priori c'est toi (ou la personne qui a développé le service) qui l'a créée...

Mais bon, peu importe l'origine de cette méthode. Je suis pas expert en webservices, mais je pense qu'il manque l'attribut <WebMethod> sur la méthode CancelAsync. Essaie de lancer le service en debug pour vérifier si CancelAsync est effectivement exécutée.
D'autre part, pourquoi y a-t-il le mot clé Overloads sur cette méthode ? Je ne vois pas d'autre surcharge...
Enfin, si CancelAsync est effectivement exécutée, elle devrait provoquer une StackOverFlowException, car elle s'appelle elle-même sans condition...

Donc à mon avis, CancelAsync n'est pas réellement exécutée par le service (peut-être à cause de l'absence de l'attribut <WebMethod>, mais c'est juste une suggestion...)

Effectivement,

Comme la méthode CancelAsync était absente du service web, c'est moi qui la créée. Si je met seulement "public sub CancelAsync", j'obtiens une erreur lors de l'insertion de mon service web dans mon application Client. C'est pour ça que j'ai ajouté le mot clé "Overloads".

Si je suis le déroulement en mode débug, tu as raison, il ne passe pas dans la méthode CancelAsync. Je ne crois pas qu'il manque le mot clé WebMethod puisqu'elle ne devrait pas l'être.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 CancelAsync(Object) Category Method Description Cancels an asynchronous call to an XML Web service method, unless the call has already completed. Type void Character family Parameters userState Object
Pour cité un autre forum, j'ai trouvé cela:
Code:

1 2 3 4 Because of the stateless nature of HTTP - this is very difficult to achieve. The CancelAsync method will only cancel the local thread that is making the request. The web service itself has no idea this has happened.
Que faire!? 8O

23/10/2008, 23h24
tomlev

OK, je crois que je commence à comprendre... en fait CancelAsync n'est pas une méthode du WebService lui même, mais une méthode du proxy utilisé par le client. Le client ne manipule pas directement le webservice : il manipule le proxy, qui est une classe générée à partir de la description WSDL du service pour communiquer avec le service.

Comme la méthode CancelAsync du service a la même signature que celle du proxy, elle est "masquée" par celle du proxy. Il faudrait que tu lui donnes un autre nom, RequestCancellation par exemple. Et (j'insiste) que tu lui mettes l'attribut <WebMethod>, sinon elle ne sera pas dans le WSDL, et donc pas dans le proxy.

Si j'ai bien compris, la méthode CancelAsync du proxy n'a qu'un rôle technique pour la communication, pas un rôle fonctionnel. Elle ne doit pas être utilisée pour arrêter une opération sur le serveur (d'ailleurs, comment indiquerais-tu quelle opération il faut arrêter ?). Si tu veux pouvoir arrêter une opération en cours, il faut que ton service propose une méthode dédiée à cet usage (de préférence avec un nom qui ne prête pas à confusion...)
24/10/2008, 14h55
rikidude

Je crois qu'on commence à mettre le doigt sur le bobo.

La méthode CancelAsync à un paramètre UserState. Si Nothing est passer par paramètre, c'est toute les functions/procedures appeler de manière asynchrone qui seront annuler. Sinon, si tu spécifie le UserState, c'est seulement la function ou procedure visée qui sera annuler.

Donc, en plus d'appeler la méthode CancelAsync, je crois qu'il faudrait faire un autre méthode RequestCancellation, comme tu me mentionnais, avec l'attribut <WebMethod>. Cette procedure pourrais changer l'état d'une variable et ainsi dans toute les autres fonctions, tester cette variable et terminer le processus enclenché.

Aurais t'il d'autre alternative !?

Merci!
24/10/2008, 22h36
tomlev

Je ne pense pas que tu aies besoin d'appeler CancelAsync du tout en fait... cette méthode signifie, grosso modo, que tu veux annuler l'appel à tryinAsync. Celà annulera l'appel de la fonction s'il n'a pas encore été envoyé au service, mais si la méthode tryin à déjà démarré, ça n'aura aucun effet.

Sinon, je ne vois pas d'autres façons de faire que de créer une méthode RequestCancellation...
29/10/2008, 19h48
rikidude

J'ai fais une procedure RequestCancellation qui change l'état d'une variable globale à true.

Cette variable est analyser dans une boucle while de la fonction tryinAsync. Je ne sais pas pourquoi, mais la valeur est toujours faux, même si RequestCancellation est bien executé.
01/11/2008, 01h28
tomlev

fais voir le code de RequestCancellation

Voilà!

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
Imports System.Web
Imports System.Web.Services
Imports System.Web.Services.Protocols
Imports System.Threading
Imports System.IO
 
<WebService(Namespace:="http://tempuri.org/")> _
<WebServiceBinding(ConformsTo:=WsiProfiles.BasicProfile1_1)> _
<Global.Microsoft.VisualBasic.CompilerServices.DesignerGenerated()> _
Public Class Service
    Inherits System.Web.Services.WebService
 
    Private g_bln_cancel As Boolean
    Public Property Cancelation() As Boolean
        Get
            Cancelation = g_bln_cancel
        End Get
        Set(ByVal value As Boolean)
            g_bln_cancel = value
        End Set
    End Property
 
    Public Sub New()
        Cancelation = False
    End Sub
 
    <WebMethod()> _
    Public Function HelloWorld() As String
        Return "Hello World"
    End Function
 
    <WebMethod()> _
    Public Function tryin() As Boolean
        save1()
        save2()
 
        Return True
    End Function
 
    Private Sub save1()
        Dim l_obj_fichier As New StreamWriter("C:\save1.txt")
        For i As Integer = 0 To 10
            If Cancelation Then
                l_obj_fichier.WriteLine(i & " CANCELED")
                l_obj_fichier.Close()
                Exit Sub
            End If
            l_obj_fichier.WriteLine(i)
            Thread.Sleep(1000)
        Next
 
        l_obj_fichier.Close()
    End Sub
 
    Private Sub save2()
        Dim l_obj_fichier As New StreamWriter("C:\save2.txt")
        For i As Integer = 0 To 10
            If Cancelation Then
                l_obj_fichier.WriteLine(i & " CANCELED")
                l_obj_fichier.Close()
                Exit Sub
            End If
            l_obj_fichier.WriteLine(i)
            Thread.Sleep(1000)
        Next
 
        l_obj_fichier.Close()
    End Sub
 
    <WebMethod()> _
    Public Sub CustomCancel()
        Cancelation = True
    End Sub
 
End Class

Merci

03/11/2008, 15h08
tomlev

Peut-être que, tout simplement, tryin est déjà terminé quand l'appel à CustomCancel est reçu par le service... ou alors c'est une histoire de thread, genre le service qui peut exécuter une seule webmethod à la fois pour un client donné (je sais plus trop comment fonctionne la gestion des threads en webservices...)
03/11/2008, 19h49
rikidude

Bien, en debug je sais que la fonctionr d'annulation est appelé. Je sais aussi que la fonction tryin n'est pas terminé. Cependant, dans la fonction d'annulation, la variable Cancellation est bien changé à true et aussitot sortie de la fonction, c'est comme si elle n'avait jamais été changé.
03/11/2008, 22h19
tomlev

OK... alors j'ai peut-être une idée, mais j'y crois pas trop :?
Chaque thread maintient un cache des champs qu'il manipule (pour des raisons d'optimisation), si bien qu'une modification par un thread de la valeur d'un champ n'est pas forcément visible tout de suite dans les autres threads. Je ne connais pas le mécanisme exact, mais en C# il existe le modifieur volatile pour éviter qu'un champ soit mis en cache. Je ne connais pas l'équivalent en Visual Basic, mais s'il existe, tu peux essayer de l'appliquer au champ g_bln_cancel.

À défaut d'avoir le mot clé volatile de C#, en VB il faut faire quelque chose de plus tordu:

Code:

1
2
3
4
5
6
7
8
9
    Function VolatileRead(Of T)(ByRef Address As T) As T
        VolatileRead = Address
        Threading.Thread.MemoryBarrier()
    End Function
 
    Sub VolatileWrite(Of T)(ByRef Address As T, ByVal Value As T)
        Threading.Thread.MemoryBarrier()
        Address = Value
    End Sub

Mais ça ne fonctionne pas plus!

03/11/2008, 23h04
tomlev

ben là je suis un peu à court d'idées...
tu peux toujours essayer d'exécuter pas à pas ou ajouter des logs pour essayer de voir ce qui se passe