Applied-Energistics-2-tiler.../src/main/java/appeng/crafting/CraftingJob.java

376 lines
8.8 KiB
Java
Raw Normal View History

2014-11-14 12:02:52 +01:00
/*
* This file is part of Applied Energistics 2.
* Copyright (c) 2013 - 2014, AlgorithmX2, All rights reserved.
*
* Applied Energistics 2 is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Applied Energistics 2 is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Applied Energistics 2. If not, see <http://www.gnu.org/licenses/lgpl>.
*/
package appeng.crafting;
import java.util.HashMap;
import java.util.HashSet;
import java.util.concurrent.TimeUnit;
2014-12-29 21:59:05 +01:00
import com.google.common.base.Stopwatch;
import net.minecraft.nbt.NBTTagCompound;
2014-06-22 09:00:38 +02:00
import net.minecraft.world.World;
2014-12-29 21:59:05 +01:00
2014-06-05 05:54:01 +02:00
import appeng.api.AEApi;
2014-06-05 02:47:13 +02:00
import appeng.api.config.Actionable;
import appeng.api.networking.IGrid;
import appeng.api.networking.crafting.ICraftingCallback;
import appeng.api.networking.crafting.ICraftingGrid;
import appeng.api.networking.crafting.ICraftingJob;
2014-06-06 06:26:01 +02:00
import appeng.api.networking.crafting.ICraftingPatternDetails;
import appeng.api.networking.security.BaseActionSource;
2014-06-05 05:54:01 +02:00
import appeng.api.networking.storage.IStorageGrid;
import appeng.api.storage.data.IAEItemStack;
import appeng.api.storage.data.IItemList;
import appeng.core.AELog;
import appeng.hooks.TickHandler;
public class CraftingJob implements Runnable, ICraftingJob
{
IAEItemStack output;
final IItemList<IAEItemStack> storage;
final HashSet<IAEItemStack> prophecies;
boolean simulate = false;
final MECraftingInventory original;
MECraftingInventory availableCheck;
public CraftingTreeNode tree;
private BaseActionSource actionSrc;
private ICraftingCallback callback;
long bytes = 0;
final World world;
@Override
public IAEItemStack getOutput()
{
2014-12-29 15:13:47 +01:00
return this.output;
}
public CraftingJob(World w, NBTTagCompound data)
{
2014-12-29 15:13:47 +01:00
this.world = this.wrapWorld( w );
this.storage = AEApi.instance().storage().createItemList();
this.prophecies = new HashSet<IAEItemStack>();
this.original = null;
this.availableCheck = null;
}
public void refund(IAEItemStack o)
{
2014-12-29 15:13:47 +01:00
this.availableCheck.injectItems( o, Actionable.MODULATE, this.actionSrc );
}
public IAEItemStack checkUse(IAEItemStack available)
{
2014-12-29 15:13:47 +01:00
return this.availableCheck.extractItems( available, Actionable.MODULATE, this.actionSrc );
2014-06-05 02:47:13 +02:00
}
public CraftingJob(World w, IGrid grid, BaseActionSource actionSrc, IAEItemStack what, ICraftingCallback callback)
{
2014-12-29 15:13:47 +01:00
this.world = this.wrapWorld( w );
this.output = what.copy();
this.storage = AEApi.instance().storage().createItemList();
this.prophecies = new HashSet<IAEItemStack>();
this.actionSrc = actionSrc;
2014-06-05 05:54:01 +02:00
this.callback = callback;
ICraftingGrid cc = grid.getCache( ICraftingGrid.class );
IStorageGrid sg = grid.getCache( IStorageGrid.class );
2014-12-29 15:13:47 +01:00
this.original = new MECraftingInventory( sg.getItemInventory(), actionSrc, false, false, false );
2014-12-29 15:13:47 +01:00
this.tree = this.getCraftingTree( cc, what );
this.availableCheck = null;
2014-06-06 06:26:01 +02:00
}
2014-06-22 09:00:38 +02:00
private World wrapWorld(World w)
{
return w;
}
private CraftingTreeNode getCraftingTree(ICraftingGrid cc, IAEItemStack what)
2014-06-06 06:26:01 +02:00
{
return new CraftingTreeNode( cc, this, what, null, -1, 0 );
2014-06-06 06:26:01 +02:00
}
@Override
public long getByteTotal()
{
2014-12-29 15:13:47 +01:00
return this.bytes;
}
public void writeToNBT(NBTTagCompound out)
2014-06-06 06:26:01 +02:00
{
}
final IItemList<IAEItemStack> crafting = AEApi.instance().storage().createItemList();
final IItemList<IAEItemStack> missing = AEApi.instance().storage().createItemList();
public void addTask(IAEItemStack what, long crafts, ICraftingPatternDetails details, int depth)
{
if ( crafts > 0 )
{
what = what.copy();
what.setStackSize( what.getStackSize() * crafts );
2014-12-29 15:13:47 +01:00
this.crafting.add( what );
}
}
public void addMissing(IAEItemStack what)
{
what = what.copy();
2014-12-29 15:13:47 +01:00
this.missing.add( what );
}
static class TwoIntegers
{
public final long perOp = 0;
public final long times = 0;
2014-09-28 00:50:06 +02:00
}
final HashMap<String, TwoIntegers> opsAndMultiplier = new HashMap<String, TwoIntegers>();
@Override
public void run()
{
try
{
try
{
2015-01-01 22:13:10 +01:00
TickHandler.INSTANCE.registerCraftingSimulation( this.world, this );
2014-12-29 15:13:47 +01:00
this.handlePausing();
Stopwatch timer = Stopwatch.createStarted();
2014-12-29 15:13:47 +01:00
MECraftingInventory craftingInventory = new MECraftingInventory( this.original, true, false, true );
craftingInventory.ignore( this.output );
2014-12-29 15:13:47 +01:00
this.availableCheck = new MECraftingInventory( this.original, false, false, false );
this.tree.request( craftingInventory, this.output.getStackSize(), this.actionSrc );
this.tree.dive( this );
2014-12-29 15:13:47 +01:00
for (String s : this.opsAndMultiplier.keySet())
{
2014-12-29 15:13:47 +01:00
TwoIntegers ti = this.opsAndMultiplier.get( s );
AELog.crafting( s + " * " + ti.times + " = " + (ti.perOp * ti.times) );
}
2014-12-29 15:13:47 +01:00
AELog.crafting( "------------- " + this.getByteTotal() + "b real" + timer.elapsed( TimeUnit.MILLISECONDS ) + "ms" );
// if ( mode == Actionable.MODULATE )
// craftingInventory.moveItemsToStorage( storage );
}
catch (CraftBranchFailure e)
{
2014-12-29 15:13:47 +01:00
this.simulate = true;
try
{
Stopwatch timer = Stopwatch.createStarted();
2014-12-29 15:13:47 +01:00
MECraftingInventory craftingInventory = new MECraftingInventory( this.original, true, false, true );
craftingInventory.ignore( this.output );
2014-12-29 15:13:47 +01:00
this.availableCheck = new MECraftingInventory( this.original, false, false, false );
2014-12-29 15:13:47 +01:00
this.tree.setSimulate();
this.tree.request( craftingInventory, this.output.getStackSize(), this.actionSrc );
this.tree.dive( this );
2014-12-29 15:13:47 +01:00
for (String s : this.opsAndMultiplier.keySet())
{
2014-12-29 15:13:47 +01:00
TwoIntegers ti = this.opsAndMultiplier.get( s );
AELog.crafting( s + " * " + ti.times + " = " + (ti.perOp * ti.times) );
}
2014-12-29 15:13:47 +01:00
AELog.crafting( "------------- " + this.getByteTotal() + "b simulate" + timer.elapsed( TimeUnit.MILLISECONDS ) + "ms" );
}
catch (CraftBranchFailure e1)
{
AELog.error( e1 );
}
catch (CraftingCalculationFailure f)
{
AELog.error( f );
}
catch (InterruptedException e1)
{
AELog.crafting( "Crafting calculation canceled." );
2014-12-29 15:13:47 +01:00
this.finish();
return;
}
}
catch (CraftingCalculationFailure f)
{
AELog.error( f );
}
catch (InterruptedException e1)
{
AELog.crafting( "Crafting calculation canceled." );
2014-12-29 15:13:47 +01:00
this.finish();
return;
}
2014-12-29 15:13:47 +01:00
this.log( "crafting job now done" );
}
catch (Throwable t)
{
2014-12-29 15:13:47 +01:00
this.finish();
throw new RuntimeException( t );
}
2014-12-29 15:13:47 +01:00
this.finish();
}
public void finish()
{
2014-12-29 15:13:47 +01:00
if ( this.callback != null )
this.callback.calculationComplete( this );
2014-12-29 15:13:47 +01:00
this.availableCheck = null;
2014-12-29 15:13:47 +01:00
synchronized (this.monitor)
{
2014-12-29 15:13:47 +01:00
this.running = false;
this.done = true;
this.monitor.notify();
}
}
@Override
2014-06-22 09:00:38 +02:00
public boolean isSimulation()
{
2014-12-29 15:13:47 +01:00
return this.simulate;
2014-06-22 09:00:38 +02:00
}
public boolean isDone()
{
2014-12-29 15:13:47 +01:00
return this.done;
}
2014-06-22 09:00:38 +02:00
public World getWorld()
{
2014-12-29 15:13:47 +01:00
return this.world;
2014-06-22 09:00:38 +02:00
}
private boolean running = false;
private boolean done = false;
private final Object monitor = new Object();
private final Stopwatch watch = Stopwatch.createUnstarted();
private int time = 5;
/**
* returns true if this needs more simulation.
*
2014-09-27 23:17:47 +02:00
* @param milli milliseconds of simulation
* @return true if this needs more simulation
*/
public boolean simulateFor(int milli)
{
2014-12-29 15:13:47 +01:00
this.time = milli;
2014-12-29 15:13:47 +01:00
synchronized (this.monitor)
{
2014-12-29 15:13:47 +01:00
if ( this.isDone() )
return false;
2014-12-29 15:13:47 +01:00
this.watch.reset();
this.watch.start();
this.running = true;
2014-12-29 15:13:47 +01:00
this.log( "main thread is now going to sleep" );
2014-12-29 15:13:47 +01:00
this.monitor.notify();
2014-12-29 15:13:47 +01:00
while (this.running)
{
try
{
2014-12-29 15:13:47 +01:00
this.monitor.wait();
}
catch (InterruptedException ignored)
{
}
}
2014-12-29 15:13:47 +01:00
this.log( "main thread is now active" );
}
return true;
}
private int incTime = Integer.MAX_VALUE;
public void handlePausing() throws InterruptedException
{
2014-12-29 15:13:47 +01:00
if ( this.incTime++ > 100 )
{
2014-12-29 15:13:47 +01:00
this.incTime = 0;
2014-12-29 15:13:47 +01:00
synchronized (this.monitor)
{
2014-12-29 15:13:47 +01:00
if ( this.watch.elapsed( TimeUnit.MICROSECONDS ) > this.time )
{
2014-12-29 15:13:47 +01:00
this.running = false;
this.watch.stop();
this.monitor.notify();
}
2014-12-29 15:13:47 +01:00
if ( !this.running )
{
2014-12-29 15:13:47 +01:00
this.log( "crafting job will now sleep" );
2014-12-29 15:13:47 +01:00
while (!this.running)
{
2014-12-29 15:13:47 +01:00
this.monitor.wait();
}
2014-12-29 15:13:47 +01:00
this.log( "crafting job now active" );
}
}
if ( Thread.interrupted() )
throw new InterruptedException();
}
}
private void log(String string)
{
// AELog.crafting( string );
}
public void addBytes(long crafts)
{
2014-12-29 15:13:47 +01:00
this.bytes += crafts;
}
@Override
public void populatePlan(IItemList<IAEItemStack> plan)
{
2014-12-29 15:13:47 +01:00
if ( this.tree != null )
this.tree.getPlan( plan );
}
}