Piped Streams / Threads

[Sergeant_Pepper]

Hallo,

von einem Kollegen, der momentan nicht greifbar ist, habe ich die unten stehende Methode zum Komprimieren eines Strings bekommen.

Verständnisfrage: müssen die final-Schlüsselworte hier benutzt werden?

    private byte[] zip(String aData) throws Exception
    {
        PipedInputStream pipedInputStream = new PipedInputStream();
        PipedOutputStream pipedOutputStream = new PipedOutputStream(
                pipedInputStream);

        final GZIPOutputStream gzipOutputStream = new GZIPOutputStream(
                pipedOutputStream);
        final String data = aData;

        // Befüllen des gzipOutputStreams
        new Thread(new Runnable()
                        {
            public void run()
            {
                try
                {
                    gzipOutputStream.write(data.getBytes());
                    gzipOutputStream.close();
                }
                catch (IOException e)
                {
                    System.err.println("Fehler beim Komprimieren:");
                    e.printStackTrace();
                }
            }
        }).start();

        // Einlesen des Inputstreams
        BufferedInputStream input = new BufferedInputStream(pipedInputStream);

        int bufSize = 1024 * 1024;
        int bufLen = bufSize;

        byte[] result = new byte[bufLen];

        int offset = 0;
        int bytesRead = 0;

        while ((bytesRead = input.read(result, offset, bufLen - offset)) > -1)
        {
            offset += bytesRead;

            if (offset == bufLen)
            {
                bufLen += bufSize;
                byte[] temp = new byte[bufLen];
                System.arraycopy(result, 0, temp, 0, result.length);
                result = temp;
            }
        }
        input.close();

        return result;
    }

 

[Illuvatar]

Du musst Variablen immer als [c]final[/c] deklarieren, wenn du aus einer anonymen oder lokalen Klasse darauf zugreifen willst.

 

[Sergeant_Pepper]

Danke

Das hätte ich ja selber sehen können, wenn ich den Modifier mal gelöscht und dann übersetzt hätte... :-(
Hat das auch was mit konkurrierenden Zugriffen und Threads zu tun?

 

[musiKk]

Nein, das hat damit zu tun, dass die innere Klasse zu einem anderen Zeitpunkt aufgerufen wird, als sie definiert wird. Zu dem Zeitpunkt des Aufrufs können die umgebenden Variablen aber bereits geändert sein. Da ist dann die Frage, welche genommen werden sollen; die zum Zeitpunkt der Definition oder die zum Zeitpunkt des Aufrufs? Um dieser Frage komplett aus dem Weg zu gehen, wird erzwungen, dass die Werte sich nicht ändern dürfen. Falls die Objekte, auf die die Referenzen zeigen, veränderbar sind, lassen sie sich natürlich auch weiterhin modifizieren und das sieht auch die anonyme Klasse. Es geht nur um die Referenzen.

Sollte sich auch einiges an Diskussion im Netz finden lassen. Dieses Konstrukt ist übrigens ähnlich einer Closure, die es in anderen Sprachen gibt.

 

[HoaX]

Btw: Ich würde den Thread da rausnehmen, der macht doch nicht wirklich sin wenn ich direkt danach dann auf diesen Thread warte bis er fertig ist...

 

[musiKk]

Btw: Ich würde den Thread da rausnehmen, der macht doch nicht wirklich sin wenn ich direkt danach dann auf diesen Thread warte bis er fertig ist...

Wo wird denn Deiner Meinung nach auf den Thread gewartet?

 

[Sergeant_Pepper]

Bis hier schon mal vielen Dank an Euch für die hilfreichen Antworten!