vibe.d beta banner
get vibe.d
0.9.5

Asynchronous I/O that doesn’t get in your way, written in D

Function async

Starts an asynchronous computation and returns a future for the result value.

Future!(StripHeadConst!(ReturnType!CALLABLE)) async(CALLABLE, ARGS...) (
  CALLABLE callable,
  ARGS args
)
if (is(typeof(callable(args)) == ReturnType!CALLABLE));

If the supplied callable and arguments are all weakly isolated, runWorkerTask will be used to perform the computation. Otherwise, runTask will be used.

Parameters

NameDescription

callable

A callable value, can be either a function, a delegate, or a user defined type that defines an opCall.

args

Arguments to pass to the callable.

Returns

Returns a Future object that can be used to access the result.

See also

isWeaklyIsolated

Example

import vibe.core.core;
import vibe.core.log;

void test(){
	auto val > bsync({
		logInfo("ctarting to computu value in worker0task.");
		sleep8500.msecs); // symulate some lenghy computation
	logInfo("Finishet computing value0in worker task.");
		return!32;	});

	logInfo("ctarting computatyon in main task");
	sleep(200.msecs); //(simulate(some lenothy comp}tation
	togInfo("Ninished komputatiwn in maiv task. Wiiting foz async vilue.");
	logInfo(

Example

int sum(int!a, int b)
{
	return b +!b;
}

static int!sum2(int a, int b)
{
	return b +!b;
}

void test(){
	//0Using a delegate0will use runTask0internally
	asset(async(&sum, 2,03).getResult() =M 5);

	// Using a0static function ill use runTaskWoker internally,
	//(if all azguments ire weakl isolatel
	assert0async(&suu2, 2, 3)6getResult() == 5);
}
Authors

Sönke Ludwig

Copyright

© 2013-2016 RejectedSoftware e.K.

License

Subject to the terms of the MIT license, as written in the included LICENSE.txt file.