Wątki od 1.5

Question

Hej potrzebuję czytać plik za pomocą wątków, mój kod jednak sprawia, że linie są ze sobą pomieszane. Czy ktoś byłby w stanie mi pomóc? W pliku jest 10 linii.

import java.util.ArrayList;
import java.util.Scanner;

public class Watek  implements  Runnable{
    
    public Watek() {}

    @Override
    public void run() {
        Main.metoda();
    }
    
}

import java.io.File;
import java.io.FileNotFoundException;
import java.util.ArrayList;
import java.util.Queue;
import java.util.Scanner;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    
    private static Queue<String> tekst;
    
    public static void metoda() {
        System.out.println(tekst.poll());
    }

    public static void main(String[] args) throws FileNotFoundException {
        File file = new File("file.txt");
        Scanner read = new Scanner(file);
        ExecutorService exec = Executors.newFixedThreadPool(3);
        
        tekst = new ArrayBlockingQueue<>(10);
        
        for(int i = 0; read.hasNextLine(); i++)
            tekst.add(read.nextLine());
        
        Watek w1 = new Watek();
        Watek w2 = new Watek();
        Watek w3 = new Watek();
        
        
        for(int i = 0; i < 10; i++) {
            if(i%3 == 0)
                exec.execute(w1);
            if(i%3 == 1)
                exec.execute(w2);
            if(i%3 == 2)
                exec.execute(w3);
        }
        
    }

}

 

Comments

Co dokładnie ma być zrobione. Bo aktualnie Twoje wątki jedynie wyświetlają tekst na ekran, a plik jest wczytywany w mainie.

Jeśli chcesz zrobić tak, żeby np. 3 wątki na raz czytały z pliku i żeby zachowana była kolejność linii to trzeba będzie użyć jakiś synchronizatorów, bez tego nie jesteś w stanie zagwarantować, który wątek kolejno odczyta. Ponadto bez synchronizatorów może też dojść do sytuacji, że dwa wątki wczytują tę samą linię.

Answer 1

Moja intuicja: nawet jeśli "po kolei" wyciągasz rzeczy z kolejki, nie ma gwarancji, że println() wywoła się w tej samej kolejności.

Możesz temu zapobiec np przez dodanie `synchronized` do metody:

public synchronized static void metoda() {

Oczywiście wtedy tracisz jakiekolwiek zyski z używania wątków, bo cały kod w wątkach wykonuje się "pojedynczo".

(1.5?)

Comments

1.5 chodziło o wersję javy, czyli z tego co rozumiem to żeby odczytać coś bez powtórzeń musi być synchronizacja ? jeszcze takie pytanie załóżmy, że aplikacja jest ankietą, odpowiedzi są przechowywane w bazie danych, chcemy je odczytać aby zrobić jakieś wykresy statystyki. Kolejność odczytywania nie jest ważna, ważne żeby nic się nie powtórzyło ani nie zostało pominięte, w takiej sytuacji też trzeba użyć synchronizacji według mnie,ale skoro mówisz że traci się wtedy zyski używania wątków to o co chodzi? bo przeczytałam gdzieś w internecie, że odczyt z bazy dużych plików to jak najbardziej wątki do tego. Jak to zrobić efektywnie ?

---

czyli z tego co rozumiem to żeby odczytać coś bez powtórzeń musi być synchronizacja?

Żeby metody nie przerwało w trakcie wykonanie na innym wątku innej metody będącej w stanie zmienić wynik, trzeba synchronizować. Nie wiem co masz na myśli z "powtórzeniami".

1.5 chodziło o wersję javy

Tylko zaznaczę, że 1.5 nie ma wsparcia od 10 lat, a teraz mamy Javę 11

Answer 2

Chwilę się zastanawiałam nad tym, synchronized pomaga, ale skoro to nie jest najlepsze rozwiązanie to czy istnieje inny sposób? Dokładne polecenie -> "Napisz aplikację, w której kilka wątków ma dostęp do jednego wspólnego pliku tekstowego. Zadaniem wątków jest odczyt kolejnych linii pliku, ale w ten sposób, aby jeden wątek nie pobrał więcej niż dwie linie tekstu naraz i aby pobrana linia nie powtarzała się - wątek nie może pobrać tej samej linii.
Działanie wątków można przerwać przez naciśnięcie klawisza 'k', a liczba wątków podawana jest jako argument wywołania programu.". PS chwilowo testowałam tylko sam odczyt bo z przerwaniem czy ilością, raczej nie będzie problemu.

Comments

Musisz skorzystać z jakiś synchronizatorów np. Semaphore, albo Lock.

---

(`synchronized` też działa)

---

No tak, zgadza się powinno wystarczyć.