Producer/Consumer

This project is a port of UMass's Operating Systems TAs Dave Dirnfield and Calvin Chai's C/C++ Producer/Consumer project into Rust. It is a banking application that uses threads to process transactions from a ledger file concurrently.

Prerequisites

Rust 1.65.0+

Execution

$ cargo run <num_threads> <ledger_filepath>

Structures

Transaction

Fields

• id: The u16 identifier for this Transaction
• from_id: The u16 identifier of the account having its money moved
• to_id: The u16 identifier of the account receiving money
• amount: The f32 amount of money being moved
• mode: The enum Mode of transaction, a Deposit, Withdrawal, or Transfer

Bank

Fields:

• accounts: A BTreeMap of u16 identifiers to Mutex-locked f32 balances
• ledger: A Vec of Transactions
• num_transactions: The u16 number of Transactions in the ledger
• num_succeeded: The u16 number of Transactions that succeeded

Methods

Transaction::new(from_id: u16, to_id: u16, amount: f32, mode_id: u8) -> Transaction

Constructs and initializes a new Transaction object

Parameters

• id: The identifier for the new Transaction object
• from_id: The identifier of the account having its money moved
• to_id: The identifier of the account receiving money
• amount: The amount of money being moved
• mode_id: The identifier for the mode of the Transaction, where 0, 1, and 2 represent a deposit, withdrawal, or transfer, respectively.

Returns

The new Transaction object

Bank::new(num_accounts: u16, ledger_filepath: String) -> Bank

Constructs a new Bank object and initializes its accounts, ledger, num_transactions, and num_succeeded

Parameters

• num_accounts: The number of accounts to initialize
• ledger_filepath: The name of a ledger file containing transactions formatted <from_id> <to_id> <amount> <mode_num> on each line

Returns

The new Bank object

Bank::start(&mut self, num_threads: u16)

Spawns Threads to process this Bank's ledger concurrently

Parameters

• num_threads: The number of Threads to spawn
• arc_bank: The atomic reference counter to this Mutex-locked Bank

Bank::process_transaction(arc_bank: Arc<Mutex<Bank>>, thread_id: u16)

Pops a Transaction from this Bank's ledger and uses a Thread to process it concurrently

Parameters

• arc_bank: The atomic reference counter to this Mutex-locked Bank
• thread_id: The identifier of the thread processing the Transaction

Bank::deposit(&mut self, account_id: u16, amount: f32) -> bool

Deposit money into one of this Bank's accounts, incrementing num_succeeded if the deposit succeeded

Parameters

• account_id: The identifier of the account receiving the deposit
• amount: The amount of money being deposited

Returns

true if the deposit succeeded and false otherwise

Bank::withdraw(&mut self, account_id: u16, amount: f32) -> bool

Withdraws money from one of this Bank's accounts, incrementing num_succeeded if the withdrawal succeeded

Parameters

• account_id: The identifier of the account having its money withdrawn
• amount: The amount of money being withdrawn

Returns

true if the withdrawal succeeded and false otherwise

Bank::transfer(&mut self, from_id: u16, to_id: u16, amount: f32) -> bool

Transfers money from one of this Bank's accounts to another, incrementing num_succeeded if the transfer succeeded

Parameters

• from_id: The identifier of the account having money transferred from it
• to_id: The identifier of the account having money transferred to it
• amount: The amount of money being transferred

Returns

true if the transfer succeeded and false otherwise

Thanks to recent UMass MS graduate Ryan Lee for guarding guiding me through the idiosyncrasies of Rust.