implement student loader threads #3

Merged
peyman merged 2 commits from develope into main 2026-07-18 17:17:04 +00:00
12 changed files with 130 additions and 25 deletions
+10
View File
@@ -0,0 +1,10 @@
# Default ignored files
/shelf/
/workspace.xml
# Ignored default folder with query files
/queries/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml
# Editor-based HTTP Client requests
/httpRequests/
+13
View File
@@ -0,0 +1,13 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="WS-07-Multithreading-Basics-and-Hashing" />
</profile>
</annotationProcessing>
</component>
</project>
+7
View File
@@ -0,0 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
</component>
</project>
+20
View File
@@ -0,0 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://maven.devneeds.ir/" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
+12
View File
@@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" project-jdk-name="25" project-jdk-type="JavaSDK" />
</project>
Generated
+6
View File
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" />
</component>
</project>
+18 -10
View File
@@ -36,29 +36,37 @@ public class Main {
// TODO:
// Split data into 3 parts
int size = data.size();
int partSize = (int) Math.ceil(size / 3.0);
List<String> part1 = null;
List<String> part2 = null;
List<String> part3 = null;
List<String> part1 = data.subList(0, Math.min(partSize, size));
List<String> part2 = data.subList(Math.min(partSize, size), Math.min(partSize * 2, size));
List<String> part3 = data.subList(Math.min(partSize * 2, size), size);
// TODO:
StudentLoader t1 = null;
StudentLoader t2 = null;
StudentLoader t3 = null;
StudentLoader t1 = new StudentLoader(part1);
StudentLoader t2 = new StudentLoader(part2);
StudentLoader t3 = new StudentLoader(part3);
// TODO:
// start()
t1.start();
t2.start();
t3.start();
// join()
t1.join();
t2.join();
t3.join();
// merge results
manager.addStudents(t1.getStudents());
manager.addStudents(t2.getStudents());
manager.addStudents(t3.getStudents());
System.out.println("Students loaded successfully.");
}
case 2 -> {
+6 -5
View File
@@ -45,9 +45,7 @@ public class Student {
// Return custom hash
// Example:
// return id % 97;
return 0;
return id % 97;
}
@Override
@@ -57,14 +55,17 @@ public class Student {
// Step 1:
// Check null
if (obj == null || getClass() != obj.getClass()) {
return false;
}
// Step 2:
// Convert obj to Student
Student other = (Student) obj;
// Step 3:
// Compare IDs
return false;
return this.id == other.id;
}
@Override
+17 -5
View File
@@ -14,9 +14,9 @@ public class StudentManager {
// TODO:
// Merge students
// Hint:
// addAll()
if (newStudents != null){
this.students.addAll(newStudents);
}
}
@@ -27,7 +27,11 @@ public class StudentManager {
// Loop through students
// Compare IDs
for (Student student : students){
if (student.getId() == id){
return student;
}
}
return null;
}
@@ -38,11 +42,19 @@ public class StudentManager {
// Find student
// Remove student
for (int i = 0; i < students.size(); i++){
if (students.get(i).getId() == id){
students.remove(i);
return true;
}
}
return false;
}
public void printStudents() {
if (students.isEmpty()){
System.out.println("No students found.");
}
for (Student student : students) {
+20 -5
View File
@@ -26,7 +26,6 @@ public class StudentLoader extends Thread {
public void run() {
// TODO:
/*
Example line:
@@ -37,17 +36,33 @@ public class StudentLoader extends Thread {
// TODO:
// split line
String[] parts = line.split(",");
// TODO:
// read values
if (parts.length == 4){
try {
int id = Integer.parseInt(parts[0].trim());
String name = parts[1].trim();
String major = parts[2].trim();
double gpa = Double.parseDouble(parts[3].trim());
// TODO:
// create Student
// TODO:
// create Student
Student student = new Student(id, name, major, gpa);
// TODO:
// add to students list
// TODO:
// add to students list
students.add(student);
}
catch (NumberFormatException e){
System.err.println("Skipping invalid line format: " + line);
}
}
}
// to check if threads are working
// System.out.println(Thread.currentThread().getName() + " -> " + lines.size());
}
+1
View File
@@ -21,6 +21,7 @@ public class FileManager {
// TODO:
// Add line to list
lines.add(line);
}
BIN
View File
Binary file not shown.