Skip to content

Moved Creation of Thread Pool #5

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
mosshan wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Moved Creation of Thread Pool #5

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
27 changes: 13 additions & 14 deletions Java Blockchain/BlockchainMultiThreaded.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,18 +29,21 @@ public static void main(String[] args) throws InterruptedException, ExecutionExc
double startBlock;
double endBlock;

// Create the thread pool using the executor service
ExecutorService executorService = Executors.newFixedThreadPool(8);

startBlock = System.nanoTime();
// Instantiate the genesis block
Block genesisBlock = new Block(data, "", new Date().getTime());
// Mine the genesis block, to create the hash for our next block
genesisBlock.mineBlock(prefix);
genesisBlock.mineBlock(prefix, executorService);
// Validate our newly mined genesis block, using null as prev hash
while(!genesisBlock.validateBlock(blockchain, prefix))
{
// If our validation fails retry mining after resetting values
genesisBlock.setNonce(0);
genesisBlock.setTimeStamp(new Date().getTime());
genesisBlock.mineBlock(prefix);
genesisBlock.mineBlock(prefix, executorService);
}
// Add genesis block to the blockchain
blockchain.add(genesisBlock);
Expand All @@ -57,15 +60,15 @@ public static void main(String[] args) throws InterruptedException, ExecutionExc
startBlock = System.nanoTime();
// Create a new block with our line of data
Block newBlock = new Block(data, previousHash, new Date().getTime());
newBlock.mineBlock(prefix);
newBlock.mineBlock(prefix, executorService);
while(!newBlock.validateBlock(blockchain, prefix))
{
System.out.println("did not mine a block");

// If our validation fails retry mining after resetting values
newBlock.setNonce(0);
newBlock.setTimeStamp(new Date().getTime());
newBlock.mineBlock(prefix);
newBlock.mineBlock(prefix, executorService);
}
// Add our newly mined and verified block and set up values for next block
blockchain.add(newBlock);
Expand All @@ -75,6 +78,8 @@ public static void main(String[] args) throws InterruptedException, ExecutionExc
times.add(blockTime);
previousHash = newBlock.getHash();
}

executorService.shutdownNow();
// Grab miminum time, maximum time, and total time
double totalTime = 0.0;
for(Double time : times)
Expand Down Expand Up @@ -191,13 +196,10 @@ public String calculateBlockHash(){
}

// Method to mine a block
public void mineBlock(int prefix) throws InterruptedException, ExecutionException{
public void mineBlock(int prefix, ExecutorService executorService) throws InterruptedException, ExecutionException{
// Define the prefix we want to find
String prefixString = new String(new char[prefix]).replace('\0', '0');

// Create the thread pool using the executor service
ExecutorService executorService = Executors.newFixedThreadPool(8);

// Until we find a hash beginning with the correct prefix,
// meaning we have found a hash smaller than our necessary target
for(int i = 0; i < 100000; i++){
Expand All @@ -216,10 +218,7 @@ public void mineBlock(int prefix) throws InterruptedException, ExecutionExceptio
break;
}
}

executorService.shutdownNow();

return;
return;
}

// Method to validate the block
Expand Down Expand Up @@ -297,9 +296,9 @@ public String myCalculatedBlockHash(){
public String call() throws Exception {
// call the new calculate block hash method
myString = myCalculatedBlockHash();

// return the string
return myString;
}
}
}
}