fcfs_with_concurent_process.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "import multiprocessing\n",
    "import time\n",
    "\n",
    "def process_function(process_id, arrival_time, burst_time):\n",
    "    print(f\"Process {process_id} started execution at time {time.time()}\")\n",
    "    time.sleep(burst_time)\n",
    "    print(f\"Process {process_id} completed execution at time {time.time()}\")\n",
    "\n",
    "\n",
    "def fcfs_scheduling(processes):\n",
    "    # Sort the processes based on their arrival time (ascending order)\n",
    "    # This ensures that processes with earlier arrival times are scheduled first.\n",
    "    processes.sort(key=lambda p: p[1])\n",
    "\n",
    "    # Initialize the starting time of the first process as its arrival time\n",
    "    current_time = processes[0][1]\n",
    "\n",
    "    # Initialize variables to keep track of total waiting time and turnaround time\n",
    "    waiting_time_total = 0\n",
    "    turnaround_time_total = 0\n",
    "\n",
    "    # Print the table header for the process details\n",
    "    print(\"Process ID\\tArrival Time\\tBurst Time\\tWaiting Time\\tTurnaround Time\")\n",
    "\n",
    "    # Iterate through each process in the sorted order\n",
    "    for process in processes:\n",
    "        # Unpack the process details (process ID, arrival time, and burst time)\n",
    "        pid, arrival_time, burst_time = process\n",
    "\n",
    "        # Calculate the waiting time for the current process, ensuring it is non-negative\n",
    "        waiting_time = max(0, current_time - arrival_time)\n",
    "\n",
    "        # Calculate the turnaround time for the current process\n",
    "        turnaround_time = waiting_time + burst_time\n",
    "\n",
    "        # Update the total waiting time and turnaround time\n",
    "        waiting_time_total += waiting_time\n",
    "        turnaround_time_total += turnaround_time\n",
    "\n",
    "        # Print the details for the current process\n",
    "        print(f\"{pid}\\t\\t{arrival_time}\\t\\t{burst_time}\\t\\t{waiting_time}\\t\\t{turnaround_time}\")\n",
    "\n",
    "\n",
    "        \n",
    "        # Add the print statements for the process execution\n",
    "        # print(f\"Process {pid} started execution at time {current_time}\")\n",
    "        # Update the current time to the completion time of the current process\n",
    "        current_time += burst_time\n",
    "        # print(f\"Process {pid} completed execution at time {current_time}\")\n",
    "\n",
    "\n",
    "    # Calculate the average waiting time and turnaround time for all processes\n",
    "    n = len(processes)\n",
    "    avg_waiting_time = waiting_time_total / n\n",
    "    avg_turnaround_time = turnaround_time_total / n\n",
    "\n",
    "    # Print the average waiting time and average turnaround time\n",
    "    print(f\"\\nAverage Waiting Time: {avg_waiting_time:.2f}\")\n",
    "    print(f\"Average Turnaround Time: {avg_turnaround_time:.2f}\")\n",
    "\n",
    "if __name__ == \"__main__\":\n",
    "    # Example usage with user input for the number of processes\n",
    "    n = int(input(\"Enter the number of processes: \"))\n",
    "    processes = []\n",
    "\n",
    "    # Prompt the user to enter arrival time and burst time for each process\n",
    "    print(\"\\nEnter Process Arrival Time and Burst Time\")\n",
    "    for i in range(n):\n",
    "        arrival_time = float(input(f\"P[{i+1}] Arrival Time: \"))\n",
    "        burst_time = float(input(f\"P[{i+1}] Burst Time: \"))\n",
    "        processes.append((i+1, arrival_time, burst_time))\n",
    "    \n",
    "    \n",
    "    jobs = []\n",
    "    for process in processes:\n",
    "        process_id, arrival_time, burst_time = process\n",
    "        p = multiprocessing.Process(target=process_function, args=(process_id, arrival_time, burst_time))\n",
    "        jobs.append(p)\n",
    "        p.start()\n",
    "\n",
    "    for job in jobs:\n",
    "        job.join()\n",
    "\n",
    "    print(\"All processes completed execution.\")\n",
    "\n",
    "    # Call the FCFS scheduling function with the list of processes\n",
    "    fcfs_scheduling(processes)\n",
    "\n",
    "\n",
    "\n"
   ]
  }
 ],
 "metadata": {
  "language_info": {
   "name": "python"
  },
  "orig_nbformat": 4
 },
 "nbformat": 4,
 "nbformat_minor": 2
}