Comment arrêter un thread en attente dans un blocage de l'opération de lecture en Java?

J'ai un thread qui exécute le code suivant:

public void run() {
    try {
        int n = 0;
        byte[] buffer = new byte[4096];
        while ((n = in.read(buffer)) != -1) {
            out.write(buffer, 0, n);
            out.flush();
        }
    } catch (IOException e) {
        System.out.println(e);
    }
}

où in est System.in. Comment puis-je arrêter un tel thread gracieusement? Ni la fermeture de System.in, ni l'utilisation de Thread.interrupt semble fonctionner.

ce qui se passe lorsque vous utilisez l'interrompre?
Fil continue de fonctionner jusqu'à ce que Ctrl-D (EOF) est entré manuellement.

InformationsquelleAutor vitaut | 2010-11-15

8

C'est à cause du Système de lecture.dans (InputStream) est une opération de blocage.

Regardez ici Est-il possible de lire à partir d'un InputStream avec un délai d'attente?
- Merci. À l'aide de NIO FileChannel extrait de System.in permet d'arrêter le fil en fermant simplement System.in. Fermeture System.in résultats dans AsynchronousCloseException qui interrompt le blocage FileChannel.read.
InformationsquelleAutor PeterMmm
7

Vous avez trébuché sur un de 9 ans bug personne n'est prêt à les réparer. Ils disent qu'il ya quelques solutions de contournement dans ce rapport de bug. Très probablement, vous aurez besoin de trouver une autre façon de définir le timeout (occupé attente semble inévitable).

InformationsquelleAutor Denis Tulskiy
2

Vous pouvez utiliser la disponible (), méthode (qui est non-bloquant) pour vérifier si il n'y a rien à lire à l'avance.

En pseudo-java:
```
//...
while(running)
{
    if(in.available() > 0)
    {
        n = in.read(buffer);
        //do stuff with the buffer
    }
    else
    {
        Thread.sleep(500);
    }
}
//when running set to false exit gracefully here...
```
- Abritrary nombre, si vous ne dormez pas vous retrouver dans une chaude de la boucle de la filature de la CPU en attente pour disponible octets à lire. Mon hypothèse était que ce fil va passer la plupart de son temps d'attente pour l'entrée.
- À l'aide de available presque fait le tour. Le problème est que dans le cas des expressions du FOLKLORE available retourne 0 et le fil continue l'exécution. +1 pour compenser injuste -1 =)
- J'ai juste pensé à la réactivité... PeterMmms lien dit tout: stackoverflow.com/questions/804951/...
- Merci!!!! Votre réponse m'a sauvé la vie!
InformationsquelleAutor Paolo
1

J'ai eu le même problème aujourd'hui, et ce est la façon dont je l'ai fixée, à l'aide de in.ready() :
```
public void run() {
    String line;
    //Some code

    while(!Thread.currentThread().isInterrupted()){
        try {
            if (in.ready()) {
                line = in.readLine();
            } 
        } catch (Exception e) {
            try {
                Thread.currentThread().wait(500);
            } catch (InterruptedException e1) {
                //Do what we want when thread is interrupted
            }
        }
    }
}
```
- Intéressant, mais n'est-il pas de prendre beaucoup de CPU par l'exécution de la boucle tout le temps alors qu'il n'y a rien à lire?
- En réalité, c'est pourquoi j'ai pris la fil d'attente pour un certain temps chaque itération. Mais vous avez raison, il n'est pas aussi efficace qu'elle pourrait l'être. Il dépend maintenant quel est le logiciel en but.
- Sûr que cette plane encore si il n'y a pas de saut de ligne sur le stream. dans.prêt() retourne true si il y a un seul octet, dans.readLine() lit, puis s'attend toujours (forever) pour le retour à la ligne.
InformationsquelleAutor Nans
1

Est-il sécuritaire de proximité dans les flux dans l'autre thread?
Il fonctionne pour moi. Dans ce cas, in.read(...) throws exception SocketException.

InformationsquelleAutor tdx

Si vous voulez donner à l'utilisateur un certain temps pour entrer des données, peut - être à permet d'écraser les valeurs par défaut ou d'interrompre certains processus automatisé -, puis attendre d'abord et vérifier les entrées après la pause:

System.out.println("Enter value+ENTER within 5 Seconds to override default value: ");
try{
  Thread.sleep(5000);
} catch {InterruptedException e){}

try{
  int bytes = System.in.available();
  if (bytes > 0) {
    System.out.println("Using user entered data ("+size+" bytes)");
  } else {
    System.out.println("Using default value"); 
  }
} catch(IOException e) { /*handle*/ }

InformationsquelleAutor Andreas_D

-3

vous pouvez utiliser un externe drapeau pour cette

boolean flag = true;


public void run() { 
    try { 
        int n = 0; 
        byte[] buffer = new byte[4096]; 
        while ((n = in.read(buffer)) != -1 && flag) { 
            out.write(buffer, 0, n); 
            out.flush(); 
        } 
    } catch (IOException e) { 
        System.out.println(e); 
    } 
}

Qui n'interrompra pas déjà d'un appel bloquant de ce fait, il ne traite pas le problème.

InformationsquelleAutor asela38

Vous devez vous connecter pour publier un commentaire.