◆ AsynchronousChannel() [2/2]

System.Linq.Parallel.AsynchronousChannel< T >.AsynchronousChannel	(	int	index,
		int	capacity,
		int	chunkSize,
		CancellationToken	cancellationToken,
		IntValueEvent	consumerEvent )

inlinepackage

Definition at line 65 of file AsynchronousChannel.cs.

    {
        if (chunkSize == 0)
        {
            chunkSize = Scheduling.GetDefaultChunkSize<T>();
        }
        _index = index;
        _buffer = new T[capacity + 1][];
        _producerBufferIndex = 0;
        _consumerBufferIndex = 0;
        _producerEvent = new ManualResetEventSlim();
        _consumerEvent = consumerEvent;
        _chunkSize = chunkSize;
        _producerChunk = new T[chunkSize];
        _producerChunkIndex = 0;
        _cancellationToken = cancellationToken;
    }