异步映射

异步映射记录 1 到 1。

Redis 堆栈 
public <I extends java.io.Serializable> GearsBuilder<I> asyncMap​(
	gears.operations.AsyncMapOperation<T,​I> mapper)

The asyncMap function allows you to use a GearsFuture object to asynchronously map each input record in the pipe to an output record, one-to-one.

Parameters

Type parameters:

Name Description
I The template type of the returned builder

Function parameters:

Name Type Description
mapper AsyncMapOperation<T,​I> For each input record, returns a new output record

Returns

Returns a GearsBuilder object with a new template type.

Example

GearsBuilder.CreateGearsBuilder(reader).
	asyncMap(r->{
		GearsFuture<String> f = new GearsFuture<String>();
		new Thread(new Runnable() {
				
			@Override
			public void run() {
				try {
					Thread.sleep(1);
					
					f.setResult("done");
				} catch (Exception e) {
					e.printStackTrace();
				}					
			}
		}).start();
		return f;
});
RATE THIS PAGE
Back to top ↑