Main.java

import java.util.*;
import Elements.*;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.io.IOException;
import java.util.Collections;
import Structure.Words;

public class Main {
    public static void main(String[] args) {
        try {
            Thread semExclusividade = new Thread(Main::runSimultaneo);
            semExclusividade.start();

            Thread comExclusividade = new Thread(Main::runExclusivo);
            comExclusividade.start();
            
            semExclusividade.join();
            comExclusividade.join();
            
        }catch(Exception ex) {
            System.out.println("Erro ao ler o arquivo: " + ex.getMessage());
        }
    }

    public static void runSimultaneo() {
        try {
            List<Element> runnables = new ArrayList<>();

            Words palavras = new Words(LerBancoDePalavras());
            // Testar diferentes proporções
            for (int i = 0; i <= 100; i += DIFFERENCE) {
                runnables.clear();
                int readerCount = i;
                int writerCount = 100 - readerCount;
                for (int j = 0; j < readerCount; j++) {
                    Element reader = new Reader(palavras, true);
                    runnables.add(reader);
                }
                for (int k = readerCount; k < 100; k++) {
                    Element writer = new Writer(palavras);
                    runnables.add(writer);
                }
                long sum = 0;
                for (int m = 0; m < 50; m++) {
                    // Ordenar aleatório
                    Collections.shuffle(runnables);
                    List<Thread> threads = new ArrayList<>();
                    long startTime = System.currentTimeMillis();
                    // Colocar cada elemento na Thread
                    for (Element e : runnables) {
                        Thread t = new Thread(e);
                        t.start();
                        threads.add(t);
                    }
                    for (Thread t : threads) {
                        t.join();
                    }
                    long endTime = System.currentTimeMillis();
                    long duration = endTime - startTime;
                    sum += duration;
                }
                double avg = (double)sum / 50.0;
                
                try (PrintWriter escritor = new PrintWriter(new FileWriter("./Outputs/runSimultaneo.txt", true))) {
                    escritor.append(readerCount+","+writerCount+","+avg+"\n");
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            

        }  catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static int DIFFERENCE = 1;

    public static void runExclusivo(){
        List<Element> runnables = new ArrayList<>();

        try {
            Words palavras = new Words(LerBancoDePalavras());

            // Testar diferentes proporções
            for (int i = 0; i <= 100; i += DIFFERENCE) {
                runnables.clear();

                int readerCount = i;
                int writerCount = 100 - readerCount;
                for (int j = 0; j < readerCount; j++) {
                    Element reader = new Reader(palavras, false);
                    runnables.add(reader);
                }
                for (int k = readerCount; k < 100; k++) {
                    Element writer = new Writer(palavras);
                    runnables.add(writer);
                }
                long sum = 0;
                for (int m = 0; m < 50; m++) {
                    // Ordenar aleatório
                    Collections.shuffle(runnables);
                    List<Thread> threads = new ArrayList<>();
                    long startTime = System.currentTimeMillis();
                    // Colocar cada elemento na Thread
                    for (Element e : runnables) {
                        Thread t = new Thread(e);
                        t.start();
                        threads.add(t);
                    }
                    for (Thread t : threads) {
                        t.join();
                    }
                    long endTime = System.currentTimeMillis();
                    long duration = endTime - startTime;
                    sum += duration;
                }
                double avg = (double)sum / 50.0;
                
                try (PrintWriter escritor = new PrintWriter(new FileWriter("./Outputs/runExclusivo.txt", true))) {
                    escritor.append(readerCount+","+writerCount+","+avg+"\n");
                } catch (IOException e) {
                    e.printStackTrace();
                }
            } 
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static List<String> LerBancoDePalavras() throws FileNotFoundException {
        File arquivo = new File("./bd.txt");
        Scanner sc = new Scanner(arquivo);
        List<String> palavras = new ArrayList<>();
        while (sc.hasNext()) {
            palavras.add(sc.nextLine());
        }
        sc.close();
        return palavras;
    }
}