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