break dans une boucle for

Version imprimable

Voici la méthode d'une classe héritée de threading.Thread. Cette méthode est appelée dans un for de la méthode run() asynchrone.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
def _next_timestamp(self) -> Fraction:
    """Return the next timestamp to be decoded."""
    while True:
        for timestamp in sorted(set(map(Fraction, self._predictor.predict(PRED_BUFFER)))):
            print("timestamp predit", timestamp)
            if self._stop_flag:
                return StopIteration
            try:
                yield self._queues["request"].get_nowait()
                print("break")
                break  # if a new timestamp in the predictor, reset the prediction
            except queue.Empty:
                if timestamp not in self._frames:
                    print(timestamp, "n'est pas dans la queue")
                    yield timestamp
                else:
                    print(timestamp, "deja dans la queue")
        else:
            print("prediction terminee")
            yield self._queues["request"].get()

Bon, ou est le problème me diriez vous? Et bien voici ce qui se passe quand on l'appelle:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
>>> frame_anticipator = FrameAnticipator(video, 0, {})
>>> 
>>> timestamp predit 0
                      0 n'est pas dans la queue
                                               prediction terminee
 
>>> frame_anticipator.snapshot(Fraction(0))
<av.VideoFrame, pts=0 yuv420p 1280x720 at 0x71ef653cbbe0>
>>> frame_anticipator.snapshot(Fraction(1))
<av.VideoFrame, pts=968 yuv420p 1280x720 at 0x71ef653cbc40>
>>> timestamp predit 0
                      0 deja dans la queue
                                          prediction terminee
 
>>> frame_anticipator.snapshot(Fraction(2))
<av.VideoFrame, pts=1969 yuv420p 1280x720 at 0x71ef653cb400>
>>>

Jusque-là, le comportement est tout à fait attendu. Mais voyez ce que le code continue à m'afficher à l'infini juste après :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
timestamp predit 4
                      4 n'est pas dans la queue
                                               timestamp predit 8
                                                                 8 n'est pas dans la queue
                                                                                          timestamp predit 562949953421313/35184372088832
                   562949953421313/35184372088832 n'est pas dans la queue
                                                                         timestamp predit 4
                                                                                           4 deja dans la queue
                                                                                                               timestamp predit 8
           8 deja dans la queue
                               timestamp predit 562949953421313/35184372088832
                                                                              562949953421313/35184372088832 n'est pas dans la queue
              timestamp predit 4
                                4 deja dans la queue
                                                    timestamp predit 8
                                                                      8 deja dans la queue
                                                                                          timestamp predit 562949953421313/35184372088832
                   562949953421313/35184372088832 n'est pas dans la queue
                                                                         timestamp predit 4
                                                                                           4 deja dans la queue
...

Et cela a l'infinie !

Pourquoi diable n'entre-t-il pas dans le else du for, alors que break n'est jamais atteint !?:arf:

07/12/2025, 18h04
papajoker
bonjour

code trop compliqué ...

Il te suffit d'un mini script pour comprendre que fait le else avec for:
Code:

1 2 3 4 5 6 for i in range(12): print(i) if i > 5: break else: print("sortie de boucle")
Code:

1 2 3 4 5 6 for i in range(12): print(i) #if i > 5: # break else: print("sortie de boucle")
Citation:

Et cela a l'infinie

peut-être logique avec ton while True ? ta seule sortie est self._stop_flag ?
07/12/2025, 19h35
robinechuca

Pardon, il manque en effet un élément:

Code:

self._queues["request"].get()

est bloquant.
Mais la question n'est pas : pourquoi ça affiche des choses à l'infinie (en effet, ça vient du while True et c'est normal).
Justement, si ça tourne en rond à l'infini, ca veut bien dire que la boucle for est appelé plusieurs fois, et donc qu'elle termine à un moment.
Mais comment la boucle for termine-t-elle? En effet, les 2 seuls points de sorties sont "break" et "else", or les prints nous montrent que ni l'un ni l'autre n'est jamais appelé!
Un autre point de sortie pourrait être une exception, mais ce n'est pas non plus le cas, car l'exception arrêterait le while True...

Le mystère reste donc toujours entier.
08/12/2025, 02h11
josmiley

Pourquoi pas mettre un print avanr le return StopIteration pour voir, personne je trouve que c'est pas très propre de quitter le while True de cette façon.
08/12/2025, 10h51
robinechuca

J'aurais du retirer le test du self._stop_flag, qui n'est jamais atteint, car cet attribut est toujours a False. (Il n'y a pour le moment aucun endroit dans le code qui le modifie).

"prediction terminee" n'étant pas affiché je suppose que ça break à un moment , perso j'aurais mis le print en fin de boucle après le else.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
def _next_timestamp(self) -> Fraction:
    """Return the next timestamp to be decoded."""
    while True:
        for timestamp in sorted(set(map(Fraction, self._predictor.predict(PRED_BUFFER)))):
            print("timestamp predit", timestamp)
            try:
                yield self._queues["request"].get_nowait()
                break  # if a new timestamp in the predictor, reset the prediction
            except queue.Empty:
                if timestamp not in self._frames:
                    print(timestamp, "n'est pas dans la queue")
                    yield timestamp
                else:
                    print(timestamp, "deja dans la queue")
        else:
            print("prediction terminee")
            yield self._queues["request"].get()
            continue
        print("break")

08/12/2025, 17h00
fred1599

Hello,

On peut voir l'implémentation de _predictor ?
08/12/2025, 18h06
robinechuca

Bien sur!

Voici la documentation ou bien le code source.
Mais globalement, la ligne

Code:

sorted(set(map(Fraction, self._predictor.predict(PRED_BUFFER))))

renvoie juste une liste de Fractions.

Pourquoi cette curiosité? Serais-ce une piste? :calim2: