Author SHA1 Message Date
Aryan 31e359ff87 feat: Complete timeout example for threading 2026-05-24 18:29:12 +03:30
8 changed files with 121 additions and 83 deletions
+21 -29
View File
@@ -1,11 +1,9 @@
package dev; package dev;
import dev.model.Student;
import dev.service.StudentManager; import dev.service.StudentManager;
import dev.thread.StudentLoader; import dev.thread.StudentLoader;
import dev.utils.FileManager; import dev.utils.FileManager;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Scanner; import java.util.Scanner;
@@ -33,36 +31,34 @@ public class Main {
case 1 -> { case 1 -> {
List<String> data = FileManager.loadStudents("students.csv"); List<String> data = FileManager.loadStudents("students.txt");
// Split the file into three parts // TODO:
List<String> part1 = data.subList(0,(data.size()/3 - 1));
List<String> part2 = data.subList((data.size()/3 - 1), (2 * data.size()/3 - 1)); // Split data into 3 parts
List<String> part3 = data.subList(((2 * data.size()/3 - 1)), data.size()); List<String> part1 = null;
// Create a thread for each part List<String> part2 = null;
StudentLoader t1 = new StudentLoader(part1);
StudentLoader t2 = new StudentLoader(part2); List<String> part3 = null;
StudentLoader t3 = new StudentLoader(part3); // TODO:
// Starting all three threads StudentLoader t1 = null;
t1.start();
t2.start();
t3.start();
// Waiting for all threads to finish StudentLoader t2 = null;
t1.join();
t2.join(); StudentLoader t3 = null;
t3.join();
// TODO:
// start()
// join()
// merge results
// Merging all lists
manager.addStudents(t1.getStudents());
manager.addStudents(t2.getStudents());
manager.addStudents(t3.getStudents());
} }
case 2 -> { case 2 -> {
@@ -70,12 +66,8 @@ public class Main {
System.out.print("ID: "); System.out.print("ID: ");
int id = scanner.nextInt(); int id = scanner.nextInt();
try {
System.out.println(manager.searchStudent(id).toString()); System.out.println(manager.searchStudent(id));
}
catch (NullPointerException e){
System.err.println(e.getMessage());
}
} }
+21 -4
View File
@@ -40,14 +40,31 @@ public class Student {
@Override @Override
public int hashCode() { public int hashCode() {
return id % 97;
// TODO:
// Return custom hash
// Example:
// return id % 97;
return 0;
} }
@Override @Override
public boolean equals(Object obj) { public boolean equals(Object obj) {
if (obj == null) { return false; }
Student _obj = (Student) obj; // TODO:
return _obj.getId() == this.getId();
// Step 1:
// Check null
// Step 2:
// Convert obj to Student
// Step 3:
// Compare IDs
return false;
} }
@Override @Override
+18 -11
View File
@@ -10,27 +10,34 @@ public class StudentManager {
private final ArrayList<Student> students = new ArrayList<>(); private final ArrayList<Student> students = new ArrayList<>();
public void addStudents(ArrayList<Student> newStudents) { public void addStudents(ArrayList<Student> newStudents) {
students.addAll(newStudents);
// TODO:
// Merge students
// Hint:
// addAll()
} }
public Student searchStudent(int id) { public Student searchStudent(int id) {
for (Student student : students){
if (student.getId() == id){ // TODO:
return student;
} // Loop through students
}
// Compare IDs
return null; return null;
} }
public boolean removeStudent(int id) { public boolean removeStudent(int id) {
Student student = searchStudent(id); // TODO:
if (student != null){ // Find student
students.remove(student);
return true; // Remove student
}
return false; return false;
} }
+23 -12
View File
@@ -18,30 +18,41 @@ public class StudentLoader extends Thread {
private final ArrayList<Student> students = new ArrayList<>(); private final ArrayList<Student> students = new ArrayList<>();
public StudentLoader(List<String> lines) { public StudentLoader(List<String> lines) {
this.lines = lines; this.lines = lines;
} }
// Loads the database from the lines and assign its values to students array and return it
@Override @Override
public void run() { public void run() {
// TODO:
/*
Example line:
1001,Aryan,Computer Science,3.7
*/
for (String line : lines) { for (String line : lines) {
String[] values = line.split(",");
int id = Integer.parseInt(values[0]); // TODO:
String name = values[1]; // split line
String major = values[2];
double gpa = Double.parseDouble(values[3]); // TODO:
// read values
// TODO:
// create Student
// TODO:
// add to students list
students.add(new Student(
id,
name,
major,
gpa
));
} }
} }
public ArrayList<Student> getStudents() { public ArrayList<Student> getStudents() {
return students; return students;
} }
+6 -1
View File
@@ -17,10 +17,15 @@ public class FileManager {
String line; String line;
while ((line = reader.readLine()) != null) { while ((line = reader.readLine()) != null) {
lines.add(line);
// TODO:
// Add line to list
} }
reader.close(); reader.close();
return lines; return lines;
} }
@@ -6,36 +6,20 @@ import java.util.Scanner;
public class Main { public class Main {
public static void main(String[] args) { public static void main(String[] args) {
Thread th;
Thread th2;
th2 = new Thread(new Runnable() {
@Override
public void run() {
Scanner scanner = new Scanner(System.in); Scanner scanner = new Scanner(System.in);
String name; System.out.println("you have 10 seconds: ");
name = scanner.nextLine(); System.out.print("enter your name: ");
System.out.println("Hello "+ name);
System.exit(0);
}
});
th = new Thread(new Runnable(){
@Override
public void run() {
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
System.out.println("timeout!");
System.exit(0);
}
});
th.start(); MyRunnable myRunnable = new MyRunnable();
th2.start(); Thread thread = new Thread(myRunnable);
thread.setDaemon(true);
thread.start();
String name = scanner.nextLine();
System.out.println("hello " + name);
scanner.close();
} }
} }
@@ -0,0 +1,22 @@
package lecture.multithreading.timeout;
public class MyRunnable implements Runnable{
@Override
public void run(){
for (int i = 1; i <= 10 ; i++){
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("thread was interrupted");
}
if(i == 10){
System.out.println("time is up");
System.exit(0);
}
}
}
}
View File