Krpsim.py

import copy
import time


class Krpsim:
    def __init__(self, agent, delay, verbose, random=False):
        self.inventory = []
        self.agent = agent.copy()
        self.delay = delay
        self.stock = (agent.stock)
        self.verbose = verbose
        self.random = random

    @property
    def stock(self):
        return self._stock

    @stock.setter
    def stock(self, stock):
        if isinstance(stock, dict):
            self._stock = dict(stock)
        else:
            raise ValueError('Stock must be a dictionary')

    def copy(self):
        return copy.copy(self)

    def generate_inventory(self):
        if len(self.agent.get_available_process_lst()) == 0:
            return self
        i = 0

        while True and i < 1000:
            if self.random == False:
                walk = self.agent.generate_inventory(self.inventory, self.delay)
            else:
                walk = self.agent.generate_walk(self.inventory, self.delay)
            if walk == None or len(walk) == 0:
                self.stock = self.agent.stock
                self.agent.stock = self.agent.initial_stock
                i += 1
                continue
            self.inventory.extend(walk)
            if self.verbose:
                print('agent stock')
                self.agent.print_stocks(self.agent.stock)
            self.stock = self.agent.stock
            self.agent.stock = self.agent.initial_stock
            if self.inventory != None and len(self.inventory) != 0:
                break
        if i >= 1000:
            self.inventory.clear()
            self.inventory = list(self.agent.walk)
        return self

    def run(self) -> None:
        if self.verbose:
            print('start')
            print('inventory.stock:', self.stock)
        else:
            print("Evaluating ", end='')
        stock = self.optimize()
        print(" done.")
        if self.agent.finite and 'time' in self.agent.optimize:
            stock = self.optimize_time(stock)
        self.print_trace(stock)

    def optimize(self) -> dict:
        prev_indi = self.agent.copy()
        prev_indi.init_stocks()
        indi = self.copy()

        # for time measurement
        dot_interval = 0.5
        start_time = time.time()
        next_dot_time = start_time + dot_interval

        # for finite checking:
        self.agent.finite = False
        while indi.stock != prev_indi.stock:
            prev_indi = indi
            new_indi = indi.copy()
            new_indi.agent.stock = dict(indi.stock)
            new_indi.agent.initial_stock = dict(indi.stock)
            new_indi.generate_inventory()
            if self.verbose:
                print('new stock:', new_indi.stock)
            indi = new_indi.copy()

            current_time = time.time()
            if current_time >= next_dot_time:
                print('.', end='', flush=True)
                next_dot_time = current_time + dot_interval

            if current_time - start_time >= self.delay:
                break
            elif indi.stock == prev_indi.stock or len(indi.agent.get_available_process_lst()) == 0:
                self.agent.finite = True
                break
        self.inventory = list(new_indi.inventory)
        return dict(new_indi.stock)

    def optimize_time(self, stock_dict: dict) -> dict:
        min_total_cycle = float('inf')
        inventory = []
        time_stock = []
        for i in range(80):
            if len(self.inventory) != 0:
                total_cycle = self.inventory[-1][1]
                total_cycle += int(
                self.agent.process[self.inventory[len(self.inventory) - 1][0]].nb_cycle)
            else:
                total_cycle = float('inf')
            if min_total_cycle > total_cycle:
                min_total_cycle = total_cycle
                inventory = list(self.inventory)
                time_stock = dict(stock_dict)
            elif min_total_cycle == total_cycle:
                for optimize in self.agent.optimize:
                    if optimize != 'time' and len(time_stock) != 0 and time_stock[optimize] < stock[optimize]:
                        inventory = list(self.inventory)
                        time_stock = dict(stock_dict)
            self.agent.cycle = 0
            self.inventory.clear()
            stock = self.optimize()
        self.inventory.clear()
        self.inventory = list(inventory)
        return time_stock


    def print_trace(self, stock_dict: dict) -> None:
        print("Main walk")
        if len(self.inventory) != 0:
            total_cycle = self.inventory[-1][1]
        else:
            total_cycle = 0
        biggest_cycle = 0
        for item in self.inventory:
            if (int(self.agent.process[item[0]].nb_cycle) > biggest_cycle):
                biggest_cycle = int(self.agent.process[item[0]].nb_cycle)
            print(f"{item[1]}:{item[0]}")

        if len(self.inventory) != 0:
            total_cycle += int(
            self.agent.process[self.inventory[len(self.inventory) - 1][0]].nb_cycle)

        if self.agent.finite is True:
            print(f"no more process doable at time {total_cycle + 1}")

        print("Stock :")
        for key, value in stock_dict.items():
            print(f" {key} => {value}")