a50809bc91
.NET Build and Publish / build (push) Has been cancelled
* Quick pass * no locks * github actions * publish via github actions * pack * Parent non-optional * Generics are fun * second pass * Group workers, CTS, and Task in a class for simpler nullability * pollysharp * reverted cancellation changes * reset state * Update samples * changes * still working * the fix * private workers * comments * comments 2 * comments 3 * public worker count
126 lines
3.9 KiB
C#
126 lines
3.9 KiB
C#
using System.Windows.Forms;
|
|
using Grasshopper.Kernel;
|
|
using GrasshopperAsyncComponent;
|
|
|
|
namespace GrasshopperAsyncComponentDemo.SampleImplementations;
|
|
|
|
public class Sample_UselessCyclesAsyncComponent : GH_AsyncComponent<Sample_UselessCyclesAsyncComponent>
|
|
{
|
|
public override Guid ComponentGuid => new Guid("DF2B93E2-052D-4BE4-BC62-90DC1F169BF6");
|
|
|
|
protected override System.Drawing.Bitmap Icon => Properties.Resources.logo32;
|
|
|
|
public override GH_Exposure Exposure => GH_Exposure.primary;
|
|
|
|
public Sample_UselessCyclesAsyncComponent()
|
|
: base("Sample Async Component", "CYCLOMATRON-X", "Spins uselessly.", "Samples", "Async")
|
|
{
|
|
BaseWorker = new UselessCyclesWorker(this);
|
|
}
|
|
|
|
private sealed class UselessCyclesWorker(
|
|
Sample_UselessCyclesAsyncComponent parent,
|
|
string id = "baseworker",
|
|
CancellationToken cancellationToken = default
|
|
) : WorkerInstance<Sample_UselessCyclesAsyncComponent>(parent, id, cancellationToken)
|
|
{
|
|
private int MaxIterations { get; set; } = 100;
|
|
|
|
public override Task DoWork(Action<string, double> reportProgress, Action done)
|
|
{
|
|
try
|
|
{
|
|
RunUselessCycles(reportProgress);
|
|
done();
|
|
}
|
|
catch (OperationCanceledException) when (CancellationToken.IsCancellationRequested)
|
|
{
|
|
//No need to call `done()` - GrasshopperAsyncComponent assumes immediate cancel,
|
|
//thus it has already performed clean-up actions that would normally be done on `done()`
|
|
}
|
|
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
public void RunUselessCycles(Action<string, double> reportProgress)
|
|
{
|
|
// Checking for cancellation
|
|
CancellationToken.ThrowIfCancellationRequested();
|
|
|
|
for (int i = 0; i <= MaxIterations; i++)
|
|
{
|
|
var sw = new SpinWait();
|
|
for (int j = 0; j <= 100; j++)
|
|
{
|
|
sw.SpinOnce();
|
|
}
|
|
|
|
reportProgress(Id, (i + 1) / (double)MaxIterations);
|
|
|
|
// Checking for cancellation
|
|
CancellationToken.ThrowIfCancellationRequested();
|
|
}
|
|
}
|
|
|
|
public override WorkerInstance<Sample_UselessCyclesAsyncComponent> Duplicate(
|
|
string id,
|
|
CancellationToken cancellationToken
|
|
) => new UselessCyclesWorker(Parent, id, cancellationToken);
|
|
|
|
public override void GetData(IGH_DataAccess da, GH_ComponentParamServer parameters)
|
|
{
|
|
if (CancellationToken.IsCancellationRequested)
|
|
{
|
|
return;
|
|
}
|
|
|
|
int maxIterations = 100;
|
|
da.GetData(0, ref maxIterations);
|
|
if (maxIterations > 1000)
|
|
{
|
|
maxIterations = 1000;
|
|
}
|
|
|
|
if (maxIterations < 10)
|
|
{
|
|
maxIterations = 10;
|
|
}
|
|
|
|
MaxIterations = maxIterations;
|
|
}
|
|
|
|
public override void SetData(IGH_DataAccess da)
|
|
{
|
|
if (CancellationToken.IsCancellationRequested)
|
|
{
|
|
return;
|
|
}
|
|
|
|
da.SetData(0, $"Hello world. Worker {Id} has spun for {MaxIterations} iterations.");
|
|
}
|
|
}
|
|
|
|
protected override void RegisterInputParams(GH_InputParamManager pManager)
|
|
{
|
|
pManager.AddIntegerParameter("N", "N", "Number of spins.", GH_ParamAccess.item);
|
|
}
|
|
|
|
protected override void RegisterOutputParams(GH_OutputParamManager pManager)
|
|
{
|
|
pManager.AddTextParameter("Output", "O", "Nothing really interesting.", GH_ParamAccess.item);
|
|
}
|
|
|
|
public override void AppendAdditionalMenuItems(ToolStripDropDown menu)
|
|
{
|
|
base.AppendAdditionalMenuItems(menu);
|
|
Menu_AppendItem(
|
|
menu,
|
|
"Cancel",
|
|
(s, e) =>
|
|
{
|
|
RequestCancellation();
|
|
}
|
|
);
|
|
}
|
|
}
|