Newer
Older
BrainWave-Task-Visualizer / TaskManager.py
import random

class TaskManager:
    def __init__(self, count):
        self.counters = {
            "right": 0,
            "left": 0,
            "neutral": 0
        }
        self.taskCounters = {
            "screen": 0,
            "sound": 0,
            "task": 0
        }
        self.sum_count = 0         # 合計の試行回数
        self.target_count = count  # 各タイプを実行する目標回数
    def reset(self):
        self.counters = {
            "right": 0,
            "left": 0,
            "neutral": 0
        }
        self.taskCounters = {
            "screen": 0,
            "sound": 0,
            "task": 0
        }
        self.sum_count = 0         # 合計の試行回数

    def get_next_type(self, mode):
        if mode == "mind":
            counters = self.counters
            available_types = ["right", "left", "neutral"]
        elif mode == "task":
            counters = self.taskCounters
            available_types = ["screen", "sound", "task"]
            
        # """
        # 現状、rightとleftが目標回数に達する かつ task(想像タスク等)が目標に達した際に無限ループになる。
        # そのため、処置としてその際taskの分を他のタスクに割り振る。
        # """
        # if self.counters["right"] == self.target_count and self.counters["left"] == self.target_count and self.taskCounters["task"] == self.target_count:
        #     list(counters.values()).index(min(list(counters.values())))
        #     available_tasks = [
        #         task_type for task_type in available_types 
        #         if counters[task_type] < self.target_count
        #     ]
        #     counters[random.choice(available_tasks)] += 1
        #     return "task"
        # すべてのタスクが目標回数に達しているか確認
        if all(count >= self.target_count for count in counters.values()):
            return None  # すべて完了
            
        # 目標回数に達していないタスクの中からランダムに選択
        available_tasks = [
            task_type for task_type in available_types 
            if counters[task_type] < self.target_count
        ]
        if not available_tasks:
            return None
        
        weights = [1 / ((counters[task] + 1) ** 2) for task in available_tasks]
        selected_task = random.choices(available_tasks, weights=weights, k=1)[0]
        counters[selected_task] += 1
        return selected_task

    def get_counts(self):
        return self.counters
    
    def get_taskCounts(self):
        return self.taskCounters
    
    def get_sum_count(self):
        return sum(list(self.counters.values()))
    
    def sub_counts(self, type, task, amount):
        self.counters[type] -= amount
        self.taskCounters[task] -= amount